[hive] branch master updated: HIVE-22485: Cross product should set the conf in UnorderedPartitionedKVEdgeConfig (Rajesh Balamohan, reviewed by Ashutosh Chauhan)

[rb...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

rbalamohan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git


The following commit(s) were added to refs/heads/master by this push:
     new 0ddeb25  HIVE-22485: Cross product should set the conf in UnorderedPartitionedKVEdgeConfig (Rajesh Balamohan, reviewed by Ashutosh Chauhan)
0ddeb25 is described below

commit 0ddeb259c308c710ec795a4dd5b38c2f5c81ce9d
Author: Rajesh Balamohan <rb...@apache.org>
AuthorDate: Mon Dec 16 04:20:25 2019 +0530

    HIVE-22485: Cross product should set the conf in UnorderedPartitionedKVEdgeConfig (Rajesh Balamohan, reviewed by Ashutosh Chauhan)
---
 ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java
index 077c94f..7524d7e 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java
@@ -544,7 +544,9 @@ public class DagUtils {
       edgeManagerDescriptor.setUserPayload(cpConfig.toUserPayload(new TezConfiguration(conf)));
       UnorderedPartitionedKVEdgeConfig cpEdgeConf =
         UnorderedPartitionedKVEdgeConfig.newBuilder(keyClass, valClass,
-          ValueHashPartitioner.class.getName()).build();
+          ValueHashPartitioner.class.getName())
+            .setFromConfiguration(conf)
+            .build();
       return cpEdgeConf.createDefaultCustomEdgeProperty(edgeManagerDescriptor);
     case SIMPLE_EDGE:
       // fallthrough