You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by jc...@apache.org on 2012/09/27 23:48:42 UTC
svn commit: r1391230 - in /pig/trunk: CHANGES.txt
src/org/apache/pig/data/utils/SedesHelper.java
Author: jcoveney
Date: Thu Sep 27 21:48:41 2012
New Revision: 1391230
URL: http://svn.apache.org/viewvc?rev=1391230&view=rev
Log:
PIG-2936: Tuple serialization bug (jcoveney)
Modified:
pig/trunk/CHANGES.txt
pig/trunk/src/org/apache/pig/data/utils/SedesHelper.java
Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1391230&r1=1391229&r2=1391230&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Thu Sep 27 21:48:41 2012
@@ -283,6 +283,8 @@ OPTIMIZATIONS
BUG FIXES
+PIG-2936: Tuple serialization bug (jcoveney)
+
PIG-2930: ant test doesn't compile in trunk (cheolsoo via daijy)
PIG-2791: Pig does not work with ViewFileSystem (rohini via daijy)
Modified: pig/trunk/src/org/apache/pig/data/utils/SedesHelper.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/data/utils/SedesHelper.java?rev=1391230&r1=1391229&r2=1391230&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/data/utils/SedesHelper.java (original)
+++ pig/trunk/src/org/apache/pig/data/utils/SedesHelper.java Thu Sep 27 21:48:41 2012
@@ -88,34 +88,34 @@ public class SedesHelper {
public static void writeGenericTuple(DataOutput out, Tuple t) throws IOException {
int sz = t.size();
switch (sz) {
- case BinInterSedes.TUPLE_0:
+ case 0:
out.writeByte(BinInterSedes.TUPLE_0);
break;
- case BinInterSedes.TUPLE_1:
+ case 1:
out.writeByte(BinInterSedes.TUPLE_1);
break;
- case BinInterSedes.TUPLE_2:
+ case 2:
out.writeByte(BinInterSedes.TUPLE_2);
break;
- case BinInterSedes.TUPLE_3:
+ case 3:
out.writeByte(BinInterSedes.TUPLE_3);
break;
- case BinInterSedes.TUPLE_4:
+ case 4:
out.writeByte(BinInterSedes.TUPLE_4);
break;
- case BinInterSedes.TUPLE_5:
+ case 5:
out.writeByte(BinInterSedes.TUPLE_5);
break;
- case BinInterSedes.TUPLE_6:
+ case 6:
out.writeByte(BinInterSedes.TUPLE_6);
break;
- case BinInterSedes.TUPLE_7:
+ case 7:
out.writeByte(BinInterSedes.TUPLE_7);
break;
- case BinInterSedes.TUPLE_8:
+ case 8:
out.writeByte(BinInterSedes.TUPLE_8);
break;
- case BinInterSedes.TUPLE_9:
+ case 9:
out.writeByte(BinInterSedes.TUPLE_9);
break;
default: