diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java index f773cb9..19da1c3 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java @@ -1015,6 +1015,9 @@ 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()); + // Removing job credential entry/ cannot be set on the tasks + conf.unset("mapreduce.job.credentials.binary"); + Utilities.stripHivePasswordDetails(conf); return conf; }