pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cheol...@apache.org
Subject svn commit: r1575643 - in /pig/branches/tez: src/org/apache/pig/backend/hadoop/executionengine/tez/TezCompiler.java test/org/apache/pig/test/TestCustomPartitioner.java
Date Sun, 09 Mar 2014 01:15:01 GMT
Author: cheolsoo
Date: Sun Mar  9 01:15:00 2014
New Revision: 1575643

URL: http://svn.apache.org/r1575643
Log:
PIG-3799: TestCustomPartitioner is broken in tez branch

Modified:
    pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezCompiler.java
    pig/branches/tez/test/org/apache/pig/test/TestCustomPartitioner.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=1575643&r1=1575642&r2=1575643&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
Sun Mar  9 01:15:00 2014
@@ -601,6 +601,7 @@ public class TezCompiler extends PhyPlan
             combinePlan.addAsLeaf(clr);
 
             addDistinctPlan(curTezOp.plan, op.getRequestedParallelism());
+            curTezOp.setRequestedParallelism(op.getRequestedParallelism());
             phyToTezOpMap.put(op, curTezOp);
         } catch (Exception e) {
             int errCode = 2034;

Modified: pig/branches/tez/test/org/apache/pig/test/TestCustomPartitioner.java
URL: http://svn.apache.org/viewvc/pig/branches/tez/test/org/apache/pig/test/TestCustomPartitioner.java?rev=1575643&r1=1575642&r2=1575643&view=diff
==============================================================================
--- pig/branches/tez/test/org/apache/pig/test/TestCustomPartitioner.java (original)
+++ pig/branches/tez/test/org/apache/pig/test/TestCustomPartitioner.java Sun Mar  9 01:15:00
2014
@@ -32,7 +32,6 @@ import java.util.Random;
 import org.apache.hadoop.fs.FileStatus;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
-import org.apache.pig.PigConfiguration;
 import org.apache.pig.PigServer;
 import org.apache.pig.data.BagFactory;
 import org.apache.pig.data.Tuple;



Mime
View raw message