HIVE-10529: Remove references to tez task context before storing operator plan in object cache (Rajesh Balamohan reviewed by Gunther Hagleitner)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/4aff07e3 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/4aff07e3 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/4aff07e3 Branch: refs/heads/llap Commit: 4aff07e3e8da9b6f946df605e369f1054e76823a Parents: e2a12c9 Author: Prasanth Jayachandran <[email protected]> Authored: Tue May 5 11:04:54 2015 -0700 Committer: Prasanth Jayachandran <[email protected]> Committed: Tue May 5 11:04:54 2015 -0700 ---------------------------------------------------------------------- ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/4aff07e3/ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java index 1cfc411..b1352f3 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java @@ -77,7 +77,7 @@ public class MapJoinOperator extends AbstractMapJoinOperator<MapJoinDesc> implem private transient String cacheKey; private transient ObjectCache cache; - private HashTableLoader loader; + protected HashTableLoader loader; private boolean loadCalled; protected transient MapJoinTableContainer[] mapJoinTables; @@ -528,6 +528,7 @@ public class MapJoinOperator extends AbstractMapJoinOperator<MapJoinDesc> implem clearAllTableContainers(); } + this.loader = null; super.closeOp(abort); }
