Updated Branches: refs/heads/trunk c66ee7884 -> c06e0b577
fetch the batch mutation just once Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/c06e0b57 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/c06e0b57 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/c06e0b57 Branch: refs/heads/trunk Commit: c06e0b57784690af9a30e639b09d7169d5fa1588 Parents: c66ee78 Author: Dave Brosius <[email protected]> Authored: Fri Jun 21 19:36:06 2013 -0400 Committer: Dave Brosius <[email protected]> Committed: Fri Jun 21 19:36:06 2013 -0400 ---------------------------------------------------------------------- src/java/org/apache/cassandra/db/BatchlogManager.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/c06e0b57/src/java/org/apache/cassandra/db/BatchlogManager.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/BatchlogManager.java b/src/java/org/apache/cassandra/db/BatchlogManager.java index 9d46739..2e1b1a7 100644 --- a/src/java/org/apache/cassandra/db/BatchlogManager.java +++ b/src/java/org/apache/cassandra/db/BatchlogManager.java @@ -179,7 +179,8 @@ public class BatchlogManager implements BatchlogManagerMBean try { - replaySerializedMutations(result.one().getBytes("data"), result.one().getLong("written_at")); + UntypedResultSet.Row batch = result.one(); + replaySerializedMutations(batch.getBytes("data"), batch.getLong("written_at")); } catch (IOException e) {
