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:56:24 UTC
svn commit: r1211191 - in /pig/branches/branch-0.9: 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:56:24 2011
New Revision: 1211191
URL: http://svn.apache.org/viewvc?rev=1211191&view=rev
Log:
PIG-2387: BinStorageRecordReader causes negative progress
Modified:
pig/branches/branch-0.9/CHANGES.txt
pig/branches/branch-0.9/src/org/apache/pig/impl/io/BinStorageRecordReader.java
pig/branches/branch-0.9/src/org/apache/pig/impl/io/InterRecordReader.java
Modified: pig/branches/branch-0.9/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.9/CHANGES.txt?rev=1211191&r1=1211190&r2=1211191&view=diff
==============================================================================
--- pig/branches/branch-0.9/CHANGES.txt (original)
+++ pig/branches/branch-0.9/CHANGES.txt Tue Dec 6 21:56:24 2011
@@ -22,6 +22,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-2379: Bug in Schema.getPigSchema(ResourceSchema rSchema) improperly adds two level access (jcoveney via dvryaboy)
Modified: pig/branches/branch-0.9/src/org/apache/pig/impl/io/BinStorageRecordReader.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.9/src/org/apache/pig/impl/io/BinStorageRecordReader.java?rev=1211191&r1=1211190&r2=1211191&view=diff
==============================================================================
--- pig/branches/branch-0.9/src/org/apache/pig/impl/io/BinStorageRecordReader.java (original)
+++ pig/branches/branch-0.9/src/org/apache/pig/impl/io/BinStorageRecordReader.java Tue Dec 6 21:56:24 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.9/src/org/apache/pig/impl/io/InterRecordReader.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.9/src/org/apache/pig/impl/io/InterRecordReader.java?rev=1211191&r1=1211190&r2=1211191&view=diff
==============================================================================
--- pig/branches/branch-0.9/src/org/apache/pig/impl/io/InterRecordReader.java (original)
+++ pig/branches/branch-0.9/src/org/apache/pig/impl/io/InterRecordReader.java Tue Dec 6 21:56:24 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;