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 e3877d9..7b5d70c 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java @@ -171,9 +171,14 @@ public void generateMapMetaData() throws HiveException, SerDeException { private void loadHashTable() throws HiveException { - if ((this.getExecContext() != null) - && ((this.getExecContext().getLocalWork() == null) || (!this.getExecContext() - .getLocalWork().getInputFileChangeSensitive()))) { + if (this.getExecContext() == null) { + if (hashTblInitedOnce) { + return; + } else { + hashTblInitedOnce = true; + } + } else if ((this.getExecContext().getLocalWork() == null) + || (!this.getExecContext().getLocalWork().getInputFileChangeSensitive())) { if (hashTblInitedOnce) { return; } else {