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 204ad6e..0c60047 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 @@ -1015,6 +1015,14 @@ public JobConf createConfiguration(HiveConf hiveConf) throws IOException { conf.set("mapred.partitioner.class", HiveConf.getVar(conf, HiveConf.ConfVars.HIVEPARTITIONER)); conf.set("tez.runtime.partitioner.class", MRPartitioner.class.getName()); + // Strip out all Hive related password information from the JobConf + if (HiveConf.getVar(conf, HiveConf.ConfVars.METASTOREPWD) != null) { + HiveConf.setVar(conf, HiveConf.ConfVars.METASTOREPWD, null); + } + if (HiveConf.getVar(conf, HiveConf.ConfVars.HIVE_SERVER2_SSL_KEYSTORE_PASSWORD) != null) { + HiveConf.setVar(conf, HiveConf.ConfVars.HIVE_SERVER2_SSL_KEYSTORE_PASSWORD, null); + } + return conf; }