pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject svn commit: r1211193 - in /pig/trunk: CHANGES.txt src/org/apache/pig/impl/io/BinStorageRecordReader.java src/org/apache/pig/impl/io/InterRecordReader.java
Date Tue, 06 Dec 2011 21:58:09 GMT
Author: daijy
Date: Tue Dec  6 21:58:09 2011
New Revision: 1211193

URL: http://svn.apache.org/viewvc?rev=1211193&view=rev
Log:
PIG-2387: BinStorageRecordReader causes negative progress

Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/src/org/apache/pig/impl/io/BinStorageRecordReader.java
    pig/trunk/src/org/apache/pig/impl/io/InterRecordReader.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1211193&r1=1211192&r2=1211193&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Tue Dec  6 21:58:09 2011
@@ -324,6 +324,8 @@ Release 0.9.2 - Unreleased
 
 BUG FIXES
 
+PIG-2387: BinStorageRecordReader causes negative progress (xutingz via daijy)
+
 PIG-2354: Several fixes for bin/pig (daijy)
 
 PIG-2385: Store statements not getting processed (daijy)

Modified: pig/trunk/src/org/apache/pig/impl/io/BinStorageRecordReader.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/impl/io/BinStorageRecordReader.java?rev=1211193&r1=1211192&r2=1211193&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/impl/io/BinStorageRecordReader.java (original)
+++ pig/trunk/src/org/apache/pig/impl/io/BinStorageRecordReader.java Tue Dec  6 21:58:09 2011
@@ -107,6 +107,7 @@ public class BinStorageRecordReader exte
           // if we got here, we have seen RECORD_1-RECORD_2-RECORD_3-TUPLE_MARKER
           // sequence - lets now read the contents of the tuple 
           value = (Tuple)DataReaderWriter.readDatum(inData, DataType.TUPLE);
+          pos=in.getPosition();
           return true;
       } catch (ExecException ee) {
           throw ee;

Modified: pig/trunk/src/org/apache/pig/impl/io/InterRecordReader.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/impl/io/InterRecordReader.java?rev=1211193&r1=1211192&r2=1211193&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/impl/io/InterRecordReader.java (original)
+++ pig/trunk/src/org/apache/pig/impl/io/InterRecordReader.java Tue Dec  6 21:58:09 2011
@@ -113,6 +113,7 @@ public class InterRecordReader extends R
           // if we got here, we have seen RECORD_1-RECORD_2-RECORD_3-TUPLE_MARKER
           // sequence - lets now read the contents of the tuple 
           value =  (Tuple)sedes.readDatum(inData, (byte)b);
+          pos=in.getPosition();
           return true;
       } catch (ExecException ee) {
           throw ee;



Mime
View raw message