cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dbros...@apache.org
Subject git commit: fetch the batch mutation just once
Date Fri, 21 Jun 2013 23:37:11 GMT
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 <dbrosius@apache.org>
Authored: Fri Jun 21 19:36:06 2013 -0400
Committer: Dave Brosius <dbrosius@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)
         {


Mime
View raw message