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/trunk Commit: 2b897d2ded8604c6340aed1fba3f7495ce36439b Parents: 36bdc25 Author: Aleksey Yeschenko <alek...@yeschenko.com> Authored: Thu Sep 21 17:01:14 2017 +0100 Committer: Aleksey Yeschenko <alek...@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-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
