You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2014/04/11 20:42:07 UTC
svn commit: r1586742 -
/pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POMergeJoin.java
Author: daijy
Date: Fri Apr 11 18:42:07 2014
New Revision: 1586742
URL: http://svn.apache.org/r1586742
Log:
PIG-3875: Fix MergeJoin_8 failure
Modified:
pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POMergeJoin.java
Modified: pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POMergeJoin.java
URL: http://svn.apache.org/viewvc/pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POMergeJoin.java?rev=1586742&r1=1586741&r2=1586742&view=diff
==============================================================================
--- pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POMergeJoin.java (original)
+++ pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POMergeJoin.java Fri Apr 11 18:42:07 2014
@@ -363,6 +363,7 @@ public class POMergeJoin extends Physica
leftTuples = newLeftTupleArray();
leftTuples.add((Tuple)prevLeftInp.result);
+ return new Result(endOfRecordMark, null);
}
else{ // This is end of all input and this is last join output.
@@ -373,8 +374,8 @@ public class POMergeJoin extends Physica
// Non-fatal error. We can continue.
log.error("Received exception while trying to close right side file: " + e.getMessage());
}
+ return new Result(POStatus.STATUS_EOP, null);
}
- return new Result(endOfRecordMark, null);
}
else{ // At this point right side can't be behind.
int errCode = 1102;