pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject svn commit: r1603631 - in /pig/trunk: CHANGES.txt src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POSplit.java
Date Wed, 18 Jun 2014 20:57:59 GMT
Author: daijy
Date: Wed Jun 18 20:57:59 2014
New Revision: 1603631

URL: http://svn.apache.org/r1603631
Log:
PIG-4020: Fix tez e2e tests MapPartialAgg_[2-4], StreamingPerformance_[6-7]

Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POSplit.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1603631&r1=1603630&r2=1603631&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Wed Jun 18 20:57:59 2014
@@ -36,6 +36,8 @@ OPTIMIZATIONS
  
 BUG FIXES
 
+PIG-4020: Fix tez e2e tests MapPartialAgg_[2-4], StreamingPerformance_[6-7] (daijy)
+
 PIG-4019: Compilation broken after TEZ-1169 (daijy)
 
 PIG-4014: Fix Rank e2e test failures on tez (daijy)

Modified: pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POSplit.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POSplit.java?rev=1603631&r1=1603630&r2=1603631&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POSplit.java
(original)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POSplit.java
Wed Jun 18 20:57:59 2014
@@ -212,7 +212,11 @@ public class POSplit extends PhysicalOpe
         if (processedSet.cardinality() == myPlans.size()) {
             
             Result inp = processInput();
-            
+
+            if (this.parentPlan.endOfAllInput) {
+                return getStreamCloseResult();
+            }
+
             if (inp.returnStatus == POStatus.STATUS_EOP
                 || inp.returnStatus == POStatus.STATUS_ERR ) {
                 return inp;



Mime
View raw message