You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ch...@apache.org on 2014/02/18 20:31:29 UTC
svn commit: r1569501 -
/pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezCompiler.java
Author: cheolsoo
Date: Tue Feb 18 19:31:28 2014
New Revision: 1569501
URL: http://svn.apache.org/r1569501
Log:
PIG-3768: TezCompiler.visitUnion() doesn't add compiled TezOp to phyToTezOpMap (cheolsoo)
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=1569501&r1=1569500&r2=1569501&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 Feb 18 19:31:28 2014
@@ -1980,9 +1980,9 @@ public class TezCompiler extends PhyPlan
pkg.setAlias(op.getAlias());
curTezOp.markUnion();
curTezOp.plan.add(pkg);
- // TODO: Union should use OnFileUnorderedKVOutput instead of
- // OnFileSortedOutput. Currently, it's not supported by Tez.
- // (TEZ-661)
+ curTezOp.setRequestedParallelism(op.getRequestedParallelism());
+ phyToTezOpMap.put(op, curTezOp);
+ // TODO: Use alias vertex that is introduced by TEZ-678
} catch (Exception e) {
int errCode = 2034;
String msg = "Error compiling operator " + op.getClass().getSimpleName();