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 f33debe1a27..9bdb1a76e73 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 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 sourceFilter) { @@ -57,6 +59,7 @@ public static Configuration copyInto(Configuration target, Configuration src, public static JobConf wrapWithJobConf(Configuration conf, Predicate sourceFilter) { JobConf jc = new JobConf(false); + copyInto(jc, defaultConf, sourceFilter); copyInto(jc, conf, sourceFilter); return jc; }