diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractMapJoinOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractMapJoinOperator.java index c8d3d64..7fa9e32 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractMapJoinOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractMapJoinOperator.java @@ -162,4 +162,11 @@ protected boolean hasAnyNulls(Object[] key) { protected boolean hasAnyNulls(MapJoinKey key) { return key.hasAnyNulls(nullsafes); } + + @Override + public void closeOp(boolean abort) throws HiveException { + super.closeOp(abort); + emptyList = null; + joinKeys = null; + } } diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/Operator.java ql/src/java/org/apache/hadoop/hive/ql/exec/Operator.java index c6e01f0..77764ea 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/Operator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/Operator.java @@ -605,6 +605,8 @@ public void close(boolean abort) throws HiveException { // call the operator specific close routine closeOp(abort); + reporter = null; + if (counterNameToEnum != null) { incrCounter(numInputRowsCntr, inputRows); incrCounter(numOutputRowsCntr, outputRows);