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 <j...@apache.org> Authored: Tue Jul 1 13:35:33 2014 -0400 Committer: Jake Luciani <j...@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;
