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/08/24 05:19:25 UTC

svn commit: r1620101 - in /pig/trunk: CHANGES.txt src/org/apache/pig/backend/hadoop/executionengine/tez/PartitionerDefinedVertexManager.java

Author: daijy
Date: Sun Aug 24 03:19:25 2014
New Revision: 1620101

URL: http://svn.apache.org/r1620101
Log:
PIG-4140: VertexManagerEvent.getUserPayload returns ReadOnlyBuffer after TEZ-1449

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=1620101&r1=1620100&r2=1620101&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Sun Aug 24 03:19:25 2014
@@ -64,6 +64,8 @@ OPTIMIZATIONS
  
 BUG FIXES
 
+PIG-4140: VertexManagerEvent.getUserPayload returns ReadOnlyBuffer after TEZ-1449 (daijy)
+
 PIG-4136: No special handling jythonjar/jrubyjar in e2e tests after PIG-4047 (daijy)
 
 PIG-4137: Fix hadoopversion 23 compilation due to TEZ-1469 (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=1620101&r1=1620100&r2=1620101&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 Sun Aug 24 03:19:25 2014
@@ -33,7 +33,6 @@ import org.apache.tez.runtime.api.Event;
 import org.apache.tez.runtime.api.events.VertexManagerEvent;
 
 import com.google.common.collect.Lists;
-import com.google.common.primitives.Ints;
 
 /**
  * VertexManagerPlugin used by sorting job of order by and skewed join. 
@@ -78,7 +77,7 @@ public class PartitionerDefinedVertexMan
         isParallelismSet = true;
         // Need to distinguish from VertexManagerEventPayloadProto emitted by OrderedPartitionedKVOutput
         if (vmEvent.getUserPayload().limit()==4) {
-            dynamicParallelism = Ints.fromByteArray(vmEvent.getUserPayload().array());
+            dynamicParallelism = vmEvent.getUserPayload().getInt();
         } else {
             return;
         }