diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/NonBlockingOpDeDupProc.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/NonBlockingOpDeDupProc.java index 5e0959a..5291851 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/NonBlockingOpDeDupProc.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/NonBlockingOpDeDupProc.java @@ -186,7 +186,9 @@ private boolean checkReferences(ExprNodeDesc expr, Set funcOutputs, Set< * @param pSEL parent operator */ private void fixContextReferences(SelectOperator cSEL, SelectOperator pSEL) { - Collection qbJoinTrees = pctx.getJoinContext().values(); + Collection qbJoinTrees = new ArrayList(); + qbJoinTrees.addAll(pctx.getJoinContext().values()); + qbJoinTrees.addAll(pctx.getMapJoinContext().values()); for (QBJoinTree qbJoinTree : qbJoinTrees) { Map> aliasToOpInfo = qbJoinTree.getAliasToOpInfo(); for (Map.Entry> entry : aliasToOpInfo.entrySet()) {