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;
}