Author: gates
Date: Thu Dec  6 16:56:04 2007
New Revision: 601940

URL: http://svn.apache.org/viewvc?rev=601940&view=rev
Log:
PIG-7 (more): Fixed bug in PigCombiner where it was writing IndexedTuples
instead of Tuples, causing Reducer to crash in some cases.


Modified:
    incubator/pig/trunk/CHANGES.txt
    incubator/pig/trunk/src/org/apache/pig/impl/mapreduceExec/PigCombine.java

Modified: incubator/pig/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/incubator/pig/trunk/CHANGES.txt?rev=601940&r1=601939&r2=601940&view=diff
==============================================================================
--- incubator/pig/trunk/CHANGES.txt (original)
+++ incubator/pig/trunk/CHANGES.txt Thu Dec  6 16:56:04 2007
@@ -43,3 +43,6 @@
 
     PIG-45: Fixed pig.pl to not assume hodrc file is named the same as
     cluster name (gates).
+
+    PIG-7 (more): Fixed bug in PigCombiner where it was writing IndexedTuples
+    instead of Tuples, causing Reducer to crash in some cases.

Modified: 
incubator/pig/trunk/src/org/apache/pig/impl/mapreduceExec/PigCombine.java
URL: 
http://svn.apache.org/viewvc/incubator/pig/trunk/src/org/apache/pig/impl/mapreduceExec/PigCombine.java?rev=601940&r1=601939&r2=601940&view=diff
==============================================================================
--- incubator/pig/trunk/src/org/apache/pig/impl/mapreduceExec/PigCombine.java 
(original)
+++ incubator/pig/trunk/src/org/apache/pig/impl/mapreduceExec/PigCombine.java 
Thu Dec  6 16:56:04 2007
@@ -91,7 +91,7 @@
 
             while (values.hasNext()) {
                 IndexedTuple it = (IndexedTuple) values.next();
-                t.getBagField(it.index + 1).add(it);
+                t.getBagField(it.index + 1).add(it.toTuple());
             }
             for (int i = 0; i < inputCount; i++) {  // XXX: shouldn't we only 
do this if INNER flag is set?
                 if (t.getBagField(1 + i).isEmpty())


Reply via email to