diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java index 1665772..f66ab90 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java @@ -78,7 +78,7 @@ private transient String cacheKey; private transient ObjectCache cache; - protected HashTableLoader loader; + private HashTableLoader loader; private boolean loadCalled; protected transient MapJoinTableContainer[] mapJoinTables; @@ -492,6 +492,7 @@ public void closeOp(boolean abort) throws HiveException { } } cache.release(cacheKey); + this.loader = null; super.closeOp(abort); }