pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject svn commit: r1211192 - in /pig/branches/branch-0.10: CHANGES.txt src/org/apache/pig/impl/io/BinStorageRecordReader.java src/org/apache/pig/impl/io/InterRecordReader.java
Date Tue, 06 Dec 2011 21:57:27 GMT
Author: daijy
Date: Tue Dec  6 21:57:27 2011
New Revision: 1211192

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

Modified:
    pig/branches/branch-0.10/CHANGES.txt
    pig/branches/branch-0.10/src/org/apache/pig/impl/io/BinStorageRecordReader.java
    pig/branches/branch-0.10/src/org/apache/pig/impl/io/InterRecordReader.java

Modified: pig/branches/branch-0.10/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.10/CHANGES.txt?rev=1211192&r1=1211191&r2=1211192&view=diff
==============================================================================
--- pig/branches/branch-0.10/CHANGES.txt (original)
+++ pig/branches/branch-0.10/CHANGES.txt Tue Dec  6 21:57:27 2011
@@ -296,6 +296,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/branches/branch-0.10/src/org/apache/pig/impl/io/BinStorageRecordReader.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.10/src/org/apache/pig/impl/io/BinStorageRecordReader.java?rev=1211192&r1=1211191&r2=1211192&view=diff
==============================================================================
--- pig/branches/branch-0.10/src/org/apache/pig/impl/io/BinStorageRecordReader.java (original)
+++ pig/branches/branch-0.10/src/org/apache/pig/impl/io/BinStorageRecordReader.java Tue Dec
 6 21:57:27 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/branches/branch-0.10/src/org/apache/pig/impl/io/InterRecordReader.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.10/src/org/apache/pig/impl/io/InterRecordReader.java?rev=1211192&r1=1211191&r2=1211192&view=diff
==============================================================================
--- pig/branches/branch-0.10/src/org/apache/pig/impl/io/InterRecordReader.java (original)
+++ pig/branches/branch-0.10/src/org/apache/pig/impl/io/InterRecordReader.java Tue Dec  6
21:57:27 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