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) {