svn commit: r1784872 - /pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POFRJoinSpark.java

[zly]

Author: zly
Date: Wed Mar  1 08:33:07 2017
New Revision: 1784872

URL: http://svn.apache.org/viewvc?rev=1784872&view=rev
Log:
PIG-5155:Fix FRJoin related issues after trunk merge (Nandor via Liyun)

Modified:
    
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POFRJoinSpark.java

Modified: 
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POFRJoinSpark.java
URL: 
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POFRJoinSpark.java?rev=1784872&r1=1784871&r2=1784872&view=diff
==============================================================================
--- 
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POFRJoinSpark.java
 (original)
+++ 
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POFRJoinSpark.java
 Wed Mar  1 08:33:07 2017
@@ -61,7 +61,7 @@ public class POFRJoinSpark extends POFRJ
             SchemaTupleFactory keySchemaTupleFactory = 
keySchemaTupleFactories[i];
 
             if (i == fragment) {
-                replicates.set(fragment, null);
+                replicates.set(i, null);
                 continue;
             }
 
@@ -80,8 +80,7 @@ public class POFRJoinSpark extends POFRJ
                 }
                 Tuple tuple = (Tuple) res.result;
                 if (isKeyNull(tuple.get(1))) continue;
-                Tuple key = mTupleFactory.newTuple(1);
-                key.set(0, tuple.get(1));
+                Object key = tuple.get(1);
                 Tuple value = getValueTuple(localRearrange, tuple);
 
                 if (replicate.get(key) == null) {