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);


Reply via email to