enable write memoization on single jobs

twitter-archive · Aug 31, 2011 · 647805b · 647805b
1 parent 673ebc6
commit 647805b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/com/twitter/flockdb/jobs/single/Single.scala b/src/main/scala/com/twitter/flockdb/jobs/single/Single.scala
@@ -121,7 +121,7 @@ extends JsonJob {
   }
 
   def writeToShard(shards: NodeSet[Shard], sourceId: Long, destinationId: Long, uuid: Long, state: State) = {
-    shards.all { (shardId, shard) =>
+    shards.skip(successes) all { (shardId, shard) =>
       state match {
         case State.Normal   => shard.add(sourceId, destinationId, uuid, updatedAt)
         case State.Removed  => shard.remove(sourceId, destinationId, uuid, updatedAt)