You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ab...@apache.org on 2019/08/23 08:47:16 UTC
[hive] branch master updated: HIVE-21828: Tez: Use a pre-parsed
TezConfiguration from DagUtils - Addendum2 (Attila Magyar via Gopal V)
This is an automated email from the ASF dual-hosted git repository.
abstractdog 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 9482a0c HIVE-21828: Tez: Use a pre-parsed TezConfiguration from DagUtils - Addendum2 (Attila Magyar via Gopal V)
9482a0c is described below
commit 9482a0c0319427d74af6829d7766c16e44938500
Author: Attila Magyar <am...@hortonworks.com>
AuthorDate: Fri Aug 23 10:36:05 2019 +0200
HIVE-21828: Tez: Use a pre-parsed TezConfiguration from DagUtils - Addendum2 (Attila Magyar via Gopal V)
Signed-off-by: Laszlo Bodor <bo...@gmail.com>
---
.../org/apache/hadoop/hive/ql/exec/tez/TezConfigurationFactory.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezConfigurationFactory.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezConfigurationFactory.java
index f33debe..9bdb1a7 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezConfigurationFactory.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezConfigurationFactory.java
@@ -25,8 +25,10 @@ import java.util.function.Predicate;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.mapred.JobConf;
+import org.apache.tez.dag.api.TezConfiguration;
public class TezConfigurationFactory {
+ private static TezConfiguration defaultConf = new TezConfiguration();
public static Configuration copyInto(Configuration target, Configuration src,
Predicate<String> sourceFilter) {
@@ -57,6 +59,7 @@ public class TezConfigurationFactory {
public static JobConf wrapWithJobConf(Configuration conf, Predicate<String> sourceFilter) {
JobConf jc = new JobConf(false);
+ copyInto(jc, defaultConf, sourceFilter);
copyInto(jc, conf, sourceFilter);
return jc;
}