From 65cd5801f53e2d9abe3cd9d557e39a425976cc6a Mon Sep 17 00:00:00 2001 From: Aleksey Yeschenko Date: Sun, 25 Aug 2013 00:22:23 +0300 Subject: [PATCH] Make Memtable.getEntyIterator() respect the cfs iterator Currently it assumes StorageSerive.getPartitioner(), which is not correct for 2i CFSs (LocalPartitioner) --- src/java/org/apache/cassandra/db/Memtable.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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() {