Repository: hive Updated Branches: refs/heads/master a16e8e9e4 -> adc9ae722
HIVE-18858: System properties in job configuration not resolved when submitting MR job (Daniel Voros via Zoltan Haindrich) Signed-off-by: Zoltan Haindrich <k...@rxd.hu> Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/adc9ae72 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/adc9ae72 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/adc9ae72 Branch: refs/heads/master Commit: adc9ae722c5cec5883fa848ea8e87f5b50b988db Parents: a16e8e9 Author: Daniel Voros <daniel.vo...@gmail.com> Authored: Wed Mar 21 08:00:18 2018 +0100 Committer: Zoltan Haindrich <k...@rxd.hu> Committed: Wed Mar 21 08:00:18 2018 +0100 ---------------------------------------------------------------------- .../java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/adc9ae72/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java index e7fe4a2..7ff8ddc 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java @@ -27,7 +27,9 @@ import java.lang.management.MemoryMXBean; import java.util.ArrayList; import java.util.Collection; import java.util.Collections; +import java.util.Iterator; import java.util.List; +import java.util.Map; import java.util.Properties; import org.apache.commons.lang.StringUtils; @@ -173,6 +175,12 @@ public class ExecDriver extends Task<MapredWork> implements Serializable, Hadoop CompilationOpContext opContext) { super.initialize(queryState, queryPlan, driverContext, opContext); + Iterator<Map.Entry<String, String>> iter = conf.iterator(); + while(iter.hasNext()) { + String key = iter.next().getKey(); + conf.set(key, conf.get(key)); + } + job = new JobConf(conf, ExecDriver.class); initializeFiles("tmpjars", getResource(conf, SessionState.ResourceType.JAR));
