Return-Path: X-Original-To: apmail-pig-commits-archive@www.apache.org Delivered-To: apmail-pig-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id B31B29A75 for ; Tue, 6 Dec 2011 21:58:33 +0000 (UTC) Received: (qmail 78283 invoked by uid 500); 6 Dec 2011 21:58:33 -0000 Delivered-To: apmail-pig-commits-archive@pig.apache.org Received: (qmail 78258 invoked by uid 500); 6 Dec 2011 21:58:33 -0000 Mailing-List: contact commits-help@pig.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@pig.apache.org Delivered-To: mailing list commits@pig.apache.org Received: (qmail 78251 invoked by uid 99); 6 Dec 2011 21:58:33 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 06 Dec 2011 21:58:33 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 06 Dec 2011 21:58:31 +0000 Received: from eris.apache.org (localhost [127.0.0.1]) by eris.apache.org (Postfix) with ESMTP id 8676A2388A56 for ; Tue, 6 Dec 2011 21:58:09 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit 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 -0000 To: commits@pig.apache.org From: daijy@apache.org X-Mailer: svnmailer-1.0.8-patched Message-Id: <20111206215809.8676A2388A56@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org 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;