cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [1/2] git commit: Clone partition key for ReadCommands to avoid netty corruption
Date Tue, 01 Jul 2014 17:38:04 GMT
Repository: cassandra
Updated Branches:
  refs/heads/cassandra-2.1 277475837 -> 5dc04e741


Clone partition key for ReadCommands to avoid netty corruption

patch by jake; reviewed by jason brown for CASSANDRA-7465


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/4c9afde7
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/4c9afde7
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/4c9afde7

Branch: refs/heads/cassandra-2.1
Commit: 4c9afde7a8fdf85932d3a86b8c0ee6f1549d6e25
Parents: 39925d2
Author: Jake Luciani <jake@apache.org>
Authored: Tue Jul 1 13:35:33 2014 -0400
Committer: Jake Luciani <jake@apache.org>
Committed: Tue Jul 1 13:35:33 2014 -0400

----------------------------------------------------------------------
 src/java/org/apache/cassandra/cql3/statements/SelectStatement.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/4c9afde7/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java b/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
index a4a5553..b454ece 100644
--- a/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
+++ b/src/java/org/apache/cassandra/cql3/statements/SelectStatement.java
@@ -345,7 +345,7 @@ public class SelectStatement implements CQLStatement, MeasurableForPreparedCache
             // We should not share the slice filter amongst the commands (hence the cloneShallow),
due to
             // SliceQueryFilter not being immutable due to its columnCounter used by the
lastCounted() method
             // (this is fairly ugly and we should change that but that's probably not a tiny
refactor to do that cleanly)
-            commands.add(ReadCommand.create(keyspace(), key, columnFamily(), now, filter.cloneShallow()));
+            commands.add(ReadCommand.create(keyspace(), ByteBufferUtil.clone(key), columnFamily(),
now, filter.cloneShallow()));
         }
 
         return commands;


Mime
View raw message