You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by zl...@apache.org on 2017/03/01 08:33:07 UTC
svn commit: r1784872 -
/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POFRJoinSpark.java
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) {