pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject svn commit: r1568902 - /pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/CombinerOptimizer.java
Date Mon, 17 Feb 2014 08:30:05 GMT
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);



Mime
View raw message