Author: pradeepkth Date: Sat Jan 31 02:00:49 2009 New Revision: 739490 URL: http://svn.apache.org/viewvc?rev=739490&view=rev Log: PIG-648: BinStorage fails when it finds markers unexpectedly in the data
Modified: hadoop/pig/trunk/CHANGES.txt hadoop/pig/trunk/src/org/apache/pig/builtin/BinStorage.java Modified: hadoop/pig/trunk/CHANGES.txt URL: http://svn.apache.org/viewvc/hadoop/pig/trunk/CHANGES.txt?rev=739490&r1=739489&r2=739490&view=diff ============================================================================== --- hadoop/pig/trunk/CHANGES.txt (original) +++ hadoop/pig/trunk/CHANGES.txt Sat Jan 31 02:00:49 2009 @@ -395,3 +395,6 @@ PIG-647: memory sized passed on pig command line does not get propagated to JobConf (sms) + + PIG-648: BinStorage fails when it finds markers unexpectedly in the data + (pradeepkth) Modified: hadoop/pig/trunk/src/org/apache/pig/builtin/BinStorage.java URL: http://svn.apache.org/viewvc/hadoop/pig/trunk/src/org/apache/pig/builtin/BinStorage.java?rev=739490&r1=739489&r2=739490&view=diff ============================================================================== --- hadoop/pig/trunk/src/org/apache/pig/builtin/BinStorage.java (original) +++ hadoop/pig/trunk/src/org/apache/pig/builtin/BinStorage.java Sat Jan 31 02:00:49 2009 @@ -46,9 +46,9 @@ public class BinStorage implements ReversibleLoadStoreFunc { - public static final byte RECORD_1 = 0x21; - public static final byte RECORD_2 = 0x31; - public static final byte RECORD_3 = 0x41; + public static final byte RECORD_1 = 0x01; + public static final byte RECORD_2 = 0x02; + public static final byte RECORD_3 = 0x03; Iterator<Tuple> i = null; protected BufferedPositionedInputStream in = null;