git commit: Clone partition key for ReadCommands to avoid netty corruption

[ja...@apache.org]

Repository: cassandra
Updated Branches:
  refs/heads/cassandra-2.1.0 39925d248 -> 4c9afde7a


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.0
Commit: 4c9afde7a8fdf85932d3a86b8c0ee6f1549d6e25
Parents: 39925d2
Author: Jake Luciani <ja...@apache.org>
Authored: Tue Jul 1 13:35:33 2014 -0400
Committer: Jake Luciani <ja...@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;