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