Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1406 from zhaown/fix-breaking-while-exceeding-max-intermediate-rows 

Fix breaking while exceeding max intermediate rows.
This commit is contained in:
Fangjin Yang 2015-07-20 13:41:22 -07:00
parent c4ed8fee56 524b05f073
commit 0481c8ca26
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
processing/src/main/java/io/druid/query/groupby/GroupByQueryEngine.java
View File

@ -364,11 +364,11 @@ public class GroupByQueryEngine
}
cursor.advance();
}
while (!cursor.isDone()) {
while (!cursor.isDone() && rowUpdater.getNumRows() < config.getMaxIntermediateRows()) {
ByteBuffer key = ByteBuffer.allocate(dimensions.size() * Ints.BYTES);
unprocessedKeys = rowUpdater.updateValues(key, dimensions);
if (unprocessedKeys != null || rowUpdater.getNumRows() > config.getMaxIntermediateRows()) {
if (unprocessedKeys != null) {
break;
}