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;