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/14 23:53:17 UTC

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

Author: daijy
Date: Tue Jan 14 22:53:17 2014
New Revision: 1558230

URL: http://svn.apache.org/r1558230
Log:
PIG-3665: TEZ-41 break pig-tez

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

Modified: pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezDagBuilder.java
URL: http://svn.apache.org/viewvc/pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezDagBuilder.java?rev=1558230&r1=1558229&r2=1558230&view=diff
==============================================================================
--- pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezDagBuilder.java (original)
+++ pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezDagBuilder.java Tue Jan 14 22:53:17 2014
@@ -98,6 +98,7 @@ import org.apache.tez.dag.api.ProcessorD
 import org.apache.tez.dag.api.TezConfiguration;
 import org.apache.tez.dag.api.Vertex;
 import org.apache.tez.mapreduce.combine.MRCombiner;
+import org.apache.tez.mapreduce.committer.MROutputCommitter;
 import org.apache.tez.mapreduce.common.MRInputSplitDistributor;
 import org.apache.tez.mapreduce.hadoop.InputSplitInfo;
 import org.apache.tez.mapreduce.hadoop.MRHelpers;
@@ -433,7 +434,8 @@ public class TezDagBuilder extends TezOp
 
             vertex.addOutput(store.getOperatorKey().toString(),
                     new OutputDescriptor(MROutput.class.getName())
-                            .setUserPayload(TezUtils.createUserPayloadFromConf(outputPayLoad)));
+                            .setUserPayload(TezUtils.createUserPayloadFromConf(outputPayLoad)),
+                            MROutputCommitter.class);
         }
 
         if (stores.size() > 0) {