You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by pr...@apache.org on 2009/01/30 03:12:18 UTC

svn commit: r739142 - in /hadoop/pig/trunk: CHANGES.txt src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java

Author: pradeepkth
Date: Fri Jan 30 02:12:18 2009
New Revision: 739142

URL: http://svn.apache.org/viewvc?rev=739142&view=rev
Log:
PIG-645: Streaming is broken with the latest trunk

Modified:
    hadoop/pig/trunk/CHANGES.txt
    hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java

Modified: hadoop/pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/pig/trunk/CHANGES.txt?rev=739142&r1=739141&r2=739142&view=diff
==============================================================================
--- hadoop/pig/trunk/CHANGES.txt (original)
+++ hadoop/pig/trunk/CHANGES.txt Fri Jan 30 02:12:18 2009
@@ -388,3 +388,5 @@
     register with SpillableMemoryManager with Combiner (pradeepkth)
 
     PIG-631: 4 Unit test failures on Windows (daijy)
+
+    PIG-645:  Streaming is broken with the latest trunk (pradeepkth)

Modified: hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java
URL: http://svn.apache.org/viewvc/hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java?rev=739142&r1=739141&r2=739142&view=diff
==============================================================================
--- hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java (original)
+++ hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java Fri Jan 30 02:12:18 2009
@@ -180,7 +180,7 @@
         }
         
         for (PhysicalOperator root : roots) {
-            root.attachInput(inpTuple);
+            root.attachInput(tf.newTupleNoCopy(inpTuple.getAll()));
         }
         try {
             runPipeline(leaf);