Pass original command.isForThrift() to SRP extra rows commands
ninja-patch by Aleksey Yeschenko; ninja-reviewed by Sam Tunnicliffe
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/2b897d2d
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/2b897d2d
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/2b897d2d
Branch: refs/heads/cassandra-3.11
Commit: 2b897d2ded8604c6340aed1fba3f7495ce36439b
Parents: 36bdc25
Author: Aleksey Yeschenko <aleksey@yeschenko.com>
Authored: Thu Sep 21 17:01:14 2017 +0100
Committer: Aleksey Yeschenko <aleksey@yeschenko.com>
Committed: Thu Sep 21 17:01:14 2017 +0100
----------------------------------------------------------------------
src/java/org/apache/cassandra/service/DataResolver.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/2b897d2d/src/java/org/apache/cassandra/service/DataResolver.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/DataResolver.java b/src/java/org/apache/cassandra/service/DataResolver.java
index 9a98ee5..f1eedd1 100644
--- a/src/java/org/apache/cassandra/service/DataResolver.java
+++ b/src/java/org/apache/cassandra/service/DataResolver.java
@@ -634,7 +634,8 @@ public class DataResolver extends ResponseResolver
if (null != lastClustering)
filter = filter.forPaging(metadata.comparator, lastClustering, false);
- return SinglePartitionReadCommand.create(command.metadata(),
+ return SinglePartitionReadCommand.create(command.isForThrift(),
+ command.metadata(),
command.nowInSec(),
command.columnFilter(),
command.rowFilter(),
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org
|