svn commit: r1675699 - in /pig/trunk: CHANGES.txt src/org/apache/pig/backend/hadoop/executionengine/tez/runtime/PigGraceShuffleVertexManager.java

[daijy]

Author: daijy
Date: Thu Apr 23 18:22:41 2015
New Revision: 1675699

URL: http://svn.apache.org/r1675699
Log:
PIG-4514: pig trunk compilation is broken - 
VertexManagerPluginContext.reconfigureVertex change

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

Modified: pig/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1675699&r1=1675698&r2=1675699&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Thu Apr 23 18:22:41 2015
@@ -64,6 +64,8 @@ PIG-4333: Split BigData tests into multi
  
 BUG FIXES
 
+PIG-4514: pig trunk compilation is broken - 
VertexManagerPluginContext.reconfigureVertex change (thejas)
+
 PIG-4503: [Pig on Tez] NPE in UnionOptimizer with multiple levels of union 
(rohini)
 
 PIG-4509: [Pig on Tez] Unassigned applications not killed on shutdown (rohini)

Modified: 
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/runtime/PigGraceShuffleVertexManager.java
URL: 
http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/runtime/PigGraceShuffleVertexManager.java?rev=1675699&r1=1675698&r2=1675699&view=diff
==============================================================================
--- 
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/runtime/PigGraceShuffleVertexManager.java
 (original)
+++ 
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/runtime/PigGraceShuffleVertexManager.java
 Thu Apr 23 18:22:41 2015
@@ -168,11 +168,7 @@ public class PigGraceShuffleVertexManage
                         edge.getEdgeSource(), edge.getEdgeDestination());
                 edgeManagers.put(entry.getKey(), edge);
             }
-            try {
-                getContext().reconfigureVertex(thisParallelism, null, 
edgeManagers);
-            } catch (TezException e) {
-                throw new RuntimeException(e);
-            }
+            getContext().reconfigureVertex(thisParallelism, null, 
edgeManagers);
             parallelismSet = true;
             LOG.info("Initialize parallelism for " + 
getContext().getVertexName() + " to " + thisParallelism);
         }