You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by go...@apache.org on 2017/03/23 17:36:45 UTC
hive git commit: HIVE-16208: Vectorization:
ProcessingModeHashAggregate::sumBatchSize is never reset (Gopal V,
reviewed by Rajesh Balamohan)
Repository: hive
Updated Branches:
refs/heads/master 24f1861e8 -> 60795505b
HIVE-16208: Vectorization: ProcessingModeHashAggregate::sumBatchSize is never reset (Gopal V, reviewed by Rajesh Balamohan)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/60795505
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/60795505
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/60795505
Branch: refs/heads/master
Commit: 60795505b5c8ff1162afcb7e93013665b228e150
Parents: 24f1861
Author: Gopal V <go...@apache.org>
Authored: Thu Mar 23 23:05:05 2017 +0530
Committer: Gopal V <go...@apache.org>
Committed: Thu Mar 23 23:05:18 2017 +0530
----------------------------------------------------------------------
.../apache/hadoop/hive/ql/exec/vector/VectorGroupByOperator.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/60795505/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorGroupByOperator.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorGroupByOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorGroupByOperator.java
index 90748e9..86d964c 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorGroupByOperator.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorGroupByOperator.java
@@ -374,6 +374,8 @@ public class VectorGroupByOperator extends Operator<GroupByDesc> implements
HiveConf.ConfVars.HIVEGROUPBYMAPINTERVAL.defaultIntVal;
}
+ sumBatchSize = 0;
+
mapKeysAggregationBuffers = new HashMap<KeyWrapper, VectorAggregationBufferRow>();
computeMemoryLimits();
LOG.debug("using hash aggregation processing mode");