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/06 22:58:09 UTC
svn commit: r1211193 - in /pig/trunk: CHANGES.txt
src/org/apache/pig/impl/io/BinStorageRecordReader.java
src/org/apache/pig/impl/io/InterRecordReader.java
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;