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/02/17 09:30:05 UTC
svn commit: r1568902 -
/pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/CombinerOptimizer.java
Author: daijy
Date: Mon Feb 17 08:30:05 2014
New Revision: 1568902
URL: http://svn.apache.org/r1568902
Log:
PIG-3759: CombinerOptimizer should not optimize cogroup case in tez
Modified:
pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/CombinerOptimizer.java
Modified: pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/CombinerOptimizer.java
URL: http://svn.apache.org/viewvc/pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/CombinerOptimizer.java?rev=1568902&r1=1568901&r2=1568902&view=diff
==============================================================================
--- pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/CombinerOptimizer.java (original)
+++ pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/CombinerOptimizer.java Mon Feb 17 08:30:05 2014
@@ -60,6 +60,9 @@ public class CombinerOptimizer extends T
if (predecessors == null) {
return;
}
+ if (predecessors.size()>1) {
+ return;
+ }
for (TezOperator from : predecessors) {
List<POLocalRearrangeTez> rearranges = PlanHelper.getPhysicalOperators(from.plan, POLocalRearrangeTez.class);