diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/HashTableLoader.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/HashTableLoader.java index 2e15922..e015378 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/HashTableLoader.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/HashTableLoader.java @@ -141,6 +141,7 @@ public void load(MapJoinTableContainer[] mapJoinTables, throw new HiveException(e); } } + this.tezContext = null; } private String describeOi(String desc, ObjectInspector keyOi) {