svn commit: r1643012 - /hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezWork.java

[pr...@apache.org]

Author: prasanthj
Date: Tue Dec  2 21:35:11 2014
New Revision: 1643012

URL: http://svn.apache.org/r1643012
Log:
HIVE-8888: Mapjoin with LateralViewJoin generates wrong plan in Tez (Gunther Hagleitner via Prasanth Jayachandran)

Modified:
    hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezWork.java

Modified: hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezWork.java
URL: http://svn.apache.org/viewvc/hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezWork.java?rev=1643012&r1=1643011&r2=1643012&view=diff
==============================================================================
--- hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezWork.java (original)
+++ hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezWork.java Tue Dec  2 21:35:11 2014
@@ -111,9 +111,16 @@ public class GenTezWork implements NodeP
       // will result into a vertex with multiple FS or RS operators.
       if (context.childToWorkMap.containsKey(operator)) {
         // if we've seen both root and child, we can bail.
+        
+        // clear out the mapjoin set. we don't need it anymore.
+        context.currentMapJoinOperators.clear();
+
+        // clear out the union set. we don't need it anymore.
+        context.currentUnionOperators.clear();
+
         return null;
       } else {
-        // At this point we don't have to do anything special in this case. Just
+        // At this point we don't have to do anything special. Just
         // run through the regular paces w/o creating a new task.
         work = context.rootToWorkMap.get(root);
       }