FAQ
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()) {

Search Discussions

Related Discussions

Discussion Navigation
viewthread | post
Discussion Overview
groupcommits @
categorieshive, hadoop
postedDec 20, '14 at 2:48p
activeDec 20, '14 at 2:48p
posts1
users1
websitehive.apache.org

1 user in discussion

Xuefu: 1 post

People

Translate

site design / logo © 2021 Grokbase