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/04/12 17:42:21 UTC
hive git commit: Vectorization: unload old hashtables before
reloadHashTable (Gopal V, reviewed by Matt McCline)
Repository: hive
Updated Branches:
refs/heads/master bd313cf36 -> e6143de2b
Vectorization: unload old hashtables before reloadHashTable (Gopal V, reviewed by Matt McCline)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/e6143de2
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/e6143de2
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/e6143de2
Branch: refs/heads/master
Commit: e6143de2b0c3f53d32db8a743119e3a8080d4f85
Parents: bd313cf
Author: Gopal V <go...@apache.org>
Authored: Wed Apr 12 23:12:04 2017 +0530
Committer: Gopal V <go...@apache.org>
Committed: Wed Apr 12 23:12:04 2017 +0530
----------------------------------------------------------------------
.../exec/vector/mapjoin/VectorMapJoinGenerateResultOperator.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/e6143de2/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/VectorMapJoinGenerateResultOperator.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/VectorMapJoinGenerateResultOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/VectorMapJoinGenerateResultOperator.java
index cb30413..c4d5113 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/VectorMapJoinGenerateResultOperator.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/VectorMapJoinGenerateResultOperator.java
@@ -531,6 +531,8 @@ public abstract class VectorMapJoinGenerateResultOperator extends VectorMapJoinC
protected void reloadHashTable(byte pos, int partitionId)
throws IOException, HiveException, SerDeException, ClassNotFoundException {
+ this.vectorMapJoinHashTable = null;
+
// The super method will reload a hash table partition of one of the small tables.
// Currently, for native vector map join it will only be one small table.
super.reloadHashTable(pos, partitionId);