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 2009/10/15 06:56:58 UTC
svn commit: r825393 -
/hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POLocalRearrange.java
Author: daijy
Date: Thu Oct 15 04:56:57 2009
New Revision: 825393
URL: http://svn.apache.org/viewvc?rev=825393&view=rev
Log:
PIG-921: Strange use case for Join which produces different results in local and map reduce mode
Modified:
hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POLocalRearrange.java
Modified: hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POLocalRearrange.java
URL: http://svn.apache.org/viewvc/hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POLocalRearrange.java?rev=825393&r1=825392&r2=825393&view=diff
==============================================================================
--- hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POLocalRearrange.java (original)
+++ hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POLocalRearrange.java Thu Oct 15 04:56:57 2009
@@ -441,7 +441,7 @@
} else {
try {
List<PhysicalOperator> preds = plan.getPredecessors(leaf);
- if (!(preds.get(0) instanceof POProject))
+ if (preds==null || !(preds.get(0) instanceof POProject))
mProjectedColsMap.put(project.getColumn(), keyIndex);
} catch (ExecException e) {
int errCode = 2070;