diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorGroupByOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorGroupByOperator.java index fef7c2a..c917e62 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorGroupByOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorGroupByOperator.java @@ -322,6 +322,8 @@ public void initialize(Configuration hconf) throws HiveException { HiveConf.ConfVars.HIVEGROUPBYMAPINTERVAL.defaultIntVal; } + sumBatchSize = 0; + mapKeysAggregationBuffers = new HashMap(); computeMemoryLimits(); LOG.debug("using hash aggregation processing mode");