Permalink
Browse files

Don't make changes to shards

  • Loading branch information...
1 parent b47ff97 commit b43c5bad4803930e3e0efb9f59a54a48d73f6aac @boazavital boazavital committed Nov 9, 2011
Showing with 2 additions and 2 deletions.
  1. +2 −2 src/main/scala/com/twitter/flockdb/jobs/Copy.scala
@@ -113,7 +113,7 @@ class Copy(shardIds: Seq[ShardId], var cursor: Copy.CopyCursor,
}
shardStates.foreach { case (shard, state) =>
- shard.writeCopies(state.diffs)
+ //shard.writeCopies(state.diffs)
Stats.incr("edges-copy", state.diffs.size)
state.diffs foreach { diff =>
diffLog.write(shard.getString + ":\t" + diff.toString() + "\n")
@@ -196,7 +196,7 @@ class MetadataCopy(shardIds: Seq[ShardId], var cursor: MetadataCopy.CopyCursor,
}
}
shardStates.foreach { case (shard, state) =>
- shard.writeMetadata(state.diffs)
+ //shard.writeMetadata(state.diffs)
Stats.incr("edges-copy", state.diffs.size)
state.diffs foreach { diff =>
diffLog.write(shard.getString + ":\t" + diff.toString() + "\n")

0 comments on commit b43c5ba

Please sign in to comment.