interrupt queries on incremental indexer

2014-06-03 17:32:14 -07:00 · 2014-06-03 17:32:14 -07:00 · c08002aa4d
parent 99c9a2cf05
commit c08002aa4d
1 changed files with 4 additions and 0 deletions
--- a/processing/src/main/java/io/druid/segment/incremental/IncrementalIndexStorageAdapter.java
+++ b/processing/src/main/java/io/druid/segment/incremental/IncrementalIndexStorageAdapter.java
@ -201,6 +201,10 @@ public class IncrementalIndexStorageAdapter implements StorageAdapter
                }

                while (baseIter.hasNext()) {
+                  if (Thread.interrupted()) {
+                    throw new QueryInterruptedException();
+                  }
+
                  currEntry.set(baseIter.next());

                  if (filterMatcher.matches()) {