You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2014/01/15 00:00:08 UTC

svn commit: r1558234 - /pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezCompiler.java

Author: daijy
Date: Tue Jan 14 23:00:08 2014
New Revision: 1558234

URL: http://svn.apache.org/r1558234
Log:
PIG-3666: Fix store after load

Modified:
    pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezCompiler.java

Modified: pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezCompiler.java
URL: http://svn.apache.org/viewvc/pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezCompiler.java?rev=1558234&r1=1558233&r2=1558234&view=diff
==============================================================================
--- pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezCompiler.java (original)
+++ pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezCompiler.java Tue Jan 14 23:00:08 2014
@@ -325,6 +325,7 @@ public class TezCompiler extends PhyPlan
                 tezPlan.add(curTezOp);
 
                 plan.disconnect(op, p);
+                oper.segmentBelow = true;
                 tezPlan.connect(oper, curTezOp);
                 phyToTezOpMap.put(op, curTezOp);
                 return;
@@ -1736,7 +1737,7 @@ public class TezCompiler extends PhyPlan
         try {
             POStoreTez store = new POStoreTez(op);
             nonBlocking(store);
-            phyToTezOpMap.put(store, curTezOp);
+            phyToTezOpMap.put(op, curTezOp);
             if (store.getSFile()!=null && store.getSFile().getFuncSpec()!=null)
                 curTezOp.UDFs.add(store.getSFile().getFuncSpec().toString());
         } catch (Exception e) {