Author: xuefu
Date: Sat Dec 20 14:48:48 2014
New Revision: 1646994
URL: http://svn.apache.org/r1646994
Log:
HIVE-9177: Fix child operator references after NonBlockingOpDeDupProc (II)
(Szehon via Xuefu)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/NonBlockingOpDeDupProc.java
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/NonBlockingOpDeDupProc.java
URL:
http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/NonBlockingOpDeDupProc.java?rev=1646994&r1=1646993&r2=1646994&view=diff
==============================================================================
---
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/NonBlockingOpDeDupProc.java
(original)
+++
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/NonBlockingOpDeDupProc.java
Sat Dec 20 14:48:48 2014
@@ -186,7 +186,9 @@ public class NonBlockingOpDeDupProc impl
* @param pSEL parent operator
*/
private void fixContextReferences(SelectOperator cSEL, SelectOperator pSEL) {
- Collection<QBJoinTree> qbJoinTrees = pctx.getJoinContext().values();
+ Collection<QBJoinTree> qbJoinTrees = new ArrayList<QBJoinTree>();
+ qbJoinTrees.addAll(pctx.getJoinContext().values());
+ qbJoinTrees.addAll(pctx.getMapJoinContext().values());
for (QBJoinTree qbJoinTree : qbJoinTrees) {
Map<String, Operator<? extends OperatorDesc>> aliasToOpInfo =
qbJoinTree.getAliasToOpInfo();
for (Map.Entry<String, Operator<? extends OperatorDesc>> entry :
aliasToOpInfo.entrySet()) {
