svn commit: r825393 - /hadoop/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POLocalRearrange.java

[daijy]

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;