pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject svn commit: r1603579 - in /pig/trunk: CHANGES.txt src/org/apache/pig/backend/hadoop/executionengine/tez/PartitionerDefinedVertexManager.java
Date Wed, 18 Jun 2014 18:55:40 GMT
Author: daijy
Date: Wed Jun 18 18:55:40 2014
New Revision: 1603579

URL: http://svn.apache.org/r1603579
Log:
PIG-4019: Compilation broken after TEZ-1169

Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/PartitionerDefinedVertexManager.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1603579&r1=1603578&r2=1603579&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Wed Jun 18 18:55:40 2014
@@ -36,6 +36,8 @@ OPTIMIZATIONS
  
 BUG FIXES
 
+PIG-4019: Compilation broken after TEZ-1169 (daijy)
+
 PIG-4014: Fix Rank e2e test failures on tez (daijy)
 
 PIG-4013: Order by multiple column fail on Tez (daijy)

Modified: pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/PartitionerDefinedVertexManager.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/PartitionerDefinedVertexManager.java?rev=1603579&r1=1603578&r2=1603579&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/PartitionerDefinedVertexManager.java
(original)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/PartitionerDefinedVertexManager.java
Wed Jun 18 18:55:40 2014
@@ -92,7 +92,7 @@ public class PartitionerDefinedVertexMan
                             new EdgeManagerDescriptor(ScatterGatherEdgeManager.class.getName());
                     edgeManagers.put(vertex, edgeManagerDescriptor);
                 }
-                context.setVertexParallelism(dynamicParallelism, null, edgeManagers);
+                context.setVertexParallelism(dynamicParallelism, null, edgeManagers, null);
             }
             List<TaskWithLocationHint> tasksToStart = Lists.newArrayListWithCapacity(dynamicParallelism);
             for (int i=0; i<dynamicParallelism; ++i) {



Mime
View raw message