bug fix for incremental index and 1 row

2013-01-29 13:23:57 -08:00 · 2013-01-29 13:23:57 -08:00 · 8fc10a61a0
parent 61569f62be
commit 8fc10a61a0
1 changed files with 1 additions and 1 deletions
--- a/server/src/main/java/com/metamx/druid/index/v1/IncrementalIndexStorageAdapter.java
+++ b/server/src/main/java/com/metamx/druid/index/v1/IncrementalIndexStorageAdapter.java
@ -215,7 +215,7 @@ public class IncrementalIndexStorageAdapter implements StorageAdapter
                          while (baseIter.hasNext()) {
                            currEntry.set(baseIter.next());
                            if (filterMatcher.matches()) {
-                              break;
+                              return;
                            }

                            numAdvanced++;