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 077c94f82b..da8f1a7136 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 @@ -65,6 +65,7 @@ import org.apache.hadoop.fs.Path; import org.apache.hadoop.fs.FileUtil; import org.apache.hadoop.hive.common.FileUtils; +import org.apache.hadoop.hive.conf.Constants; import org.apache.hadoop.hive.conf.HiveConf; import org.apache.hadoop.hive.conf.HiveConf.ConfVars; import org.apache.hadoop.hive.ql.Context; @@ -1387,6 +1388,8 @@ public JobConf createConfiguration(HiveConf hiveConf, boolean skipAMConf) throws // Removing job credential entry/ cannot be set on the tasks conf.unset("mapreduce.job.credentials.binary"); + // Removing job credential path/ cannot be set on the tasks + conf.unset(Constants.HADOOP_CREDENTIAL_PROVIDER_PATH_CONFIG); // TODO: convert this to a predicate too hiveConf.stripHiddenConfigurations(conf);