pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From z..@apache.org
Subject svn commit: r1784872 - /pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POFRJoinSpark.java
Date Wed, 01 Mar 2017 08:33:07 GMT
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) {



Mime
View raw message