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 2011/12/07 21:23:26 UTC

svn commit: r1211617 - in /pig/branches/branch-0.9: CHANGES.txt src/org/apache/pig/impl/streaming/OutputHandler.java

Author: daijy
Date: Wed Dec  7 20:23:25 2011
New Revision: 1211617

URL: http://svn.apache.org/viewvc?rev=1211617&view=rev
Log:
PIG-2374: streaming regression with dotNext

Modified:
    pig/branches/branch-0.9/CHANGES.txt
    pig/branches/branch-0.9/src/org/apache/pig/impl/streaming/OutputHandler.java

Modified: pig/branches/branch-0.9/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.9/CHANGES.txt?rev=1211617&r1=1211616&r2=1211617&view=diff
==============================================================================
--- pig/branches/branch-0.9/CHANGES.txt (original)
+++ pig/branches/branch-0.9/CHANGES.txt Wed Dec  7 20:23:25 2011
@@ -22,6 +22,8 @@ Release 0.9.2 - Unreleased
 
 BUG FIXES
 
+PIG-2374: streaming regression with dotNext (daijy)
+
 PIG-2055: inconsistent behavior in parser generated during build (rding via daijy)
 
 PIG-2387: BinStorageRecordReader causes negative progress (xutingz via daijy)

Modified: pig/branches/branch-0.9/src/org/apache/pig/impl/streaming/OutputHandler.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.9/src/org/apache/pig/impl/streaming/OutputHandler.java?rev=1211617&r1=1211616&r2=1211617&view=diff
==============================================================================
--- pig/branches/branch-0.9/src/org/apache/pig/impl/streaming/OutputHandler.java (original)
+++ pig/branches/branch-0.9/src/org/apache/pig/impl/streaming/OutputHandler.java Wed Dec  7 20:23:25 2011
@@ -89,7 +89,9 @@ public abstract class OutputHandler {
             return null;
         }
         
-        return deserializer.deserialize(value.getBytes());
+        byte[] newBytes = new byte[value.getLength()];
+        System.arraycopy(value.getBytes(), 0, newBytes, 0, value.getLength());
+        return deserializer.deserialize(newBytes);
     }
     
     /**