You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hive.apache.org by th...@apache.org on 2013/10/10 03:27:45 UTC

svn commit: r1530838 - /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java

Author: thejas
Date: Thu Oct 10 01:27:45 2013
New Revision: 1530838

URL: http://svn.apache.org/r1530838
Log:
HIVE-5497 : Hive trunk broken against hadoop 0.20.2 (Thejas M Nair via Brock Noland)

Modified:
    hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java

Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java?rev=1530838&r1=1530837&r2=1530838&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/mr/ExecDriver.java Thu Oct 10 01:27:45 2013
@@ -650,10 +650,12 @@ public class ExecDriver extends Task<Map
       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);