diff --git a/src/java/org/apache/cassandra/db/ReadCommandVerbHandler.java b/src/java/org/apache/cassandra/db/ReadCommandVerbHandler.java index 2759e78ec8..e39e8a8552 100644 --- a/src/java/org/apache/cassandra/db/ReadCommandVerbHandler.java +++ b/src/java/org/apache/cassandra/db/ReadCommandVerbHandler.java @@ -81,7 +81,7 @@ public class ReadCommandVerbHandler implements IVerbHandler ReadCommand command = message.payload; Token token; - if (command.isLimitedToOnePartition()) + if (command instanceof SinglePartitionReadCommand) token = ((SinglePartitionReadCommand) command).partitionKey().getToken(); else token = ((PartitionRangeReadCommand) command).dataRange().keyRange().right.getToken();