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 6d6df6c..867f252 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 @@ -649,10 +649,12 @@ public static void main(String[] args) throws IOException, HiveException { conf.set("tmpfiles", files); } - String hadoopAuthToken = - System.getenv(ShimLoader.getHadoopShims().getTokenFileLocEnvName()); - if(hadoopAuthToken != null){ - conf.set("mapreduce.job.credentials.binary", hadoopAuthToken); + if(ShimLoader.getHadoopShims().isSecurityEnabled()){ + String hadoopAuthToken = + System.getenv(ShimLoader.getHadoopShims().getTokenFileLocEnvName()); + if(hadoopAuthToken != null){ + conf.set("mapreduce.job.credentials.binary", hadoopAuthToken); + } } boolean isSilent = HiveConf.getBoolVar(conf, HiveConf.ConfVars.HIVESESSIONSILENT);