diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/GroupByOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/GroupByOperator.java index 46f0ecd..073147f 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/GroupByOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/GroupByOperator.java @@ -893,7 +893,11 @@ private boolean shouldBeFlushed(KeyWrapper newKeys) { usedMemory = isLlap ? usedMemory / numExecutors : usedMemory; rate = (float) usedMemory / (float) maxMemory; if(rate > memoryThreshold){ - return true; + if (isTez && numEntriesHashTable == 0) { + return false; + } else { + return true; + } } for (Integer pos : keyPositionsSize) { Object key = newKeys.getKeyArray()[pos.intValue()];