pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject svn commit: r1211617 - in /pig/branches/branch-0.9: CHANGES.txt src/org/apache/pig/impl/streaming/OutputHandler.java
Date Wed, 07 Dec 2011 20:23:26 GMT
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);
     }
     
     /**



Mime
View raw message