diff --git a/src/java/org/apache/cassandra/db/Memtable.java b/src/java/org/apache/cassandra/db/Memtable.java index b3ea3a2523..3490a35aa7 100644 --- a/src/java/org/apache/cassandra/db/Memtable.java +++ b/src/java/org/apache/cassandra/db/Memtable.java @@ -291,9 +291,9 @@ public class Memtable { return new Iterator>() { - private Iterator> iter = stopAt.isMinimum() - ? rows.tailMap(startWith).entrySet().iterator() - : rows.subMap(startWith, true, stopAt, true).entrySet().iterator(); + private Iterator> iter = stopAt.isMinimum(cfs.partitioner) + ? rows.tailMap(startWith).entrySet().iterator() + : rows.subMap(startWith, true, stopAt, true).entrySet().iterator(); public boolean hasNext() {