You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by db...@apache.org on 2013/06/22 01:37:11 UTC
git commit: fetch the batch mutation just once
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 <db...@apache.org>
Authored: Fri Jun 21 19:36:06 2013 -0400
Committer: Dave Brosius <db...@apache.org>
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)
{