HIVE-24159: Kafka storage handler broken in secure environment pt2: s…

…hort-circuit on non-secure environment (#1495) (Laszlo Bodor reviewed by Ashutosh Chauhan))
apache · Sep 21, 2020 · f9d6e84 · f9d6e84
1 parent 03d2a39
commit f9d6e84
Showing 1 changed file with 3 additions and 0 deletions.
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
@@ -285,6 +285,9 @@ public URI apply(Path path) {
   }
 
   private void getKafkaCredentials(MapWork work, DAG dag, JobConf conf) {
+    if (!UserGroupInformation.isSecurityEnabled()){
+      return;
+    }
     Token<?> tokenCheck = dag.getCredentials().getToken(KAFKA_DELEGATION_TOKEN_KEY);
     if (tokenCheck != null) {
       LOG.debug("Kafka credentials already added, skipping...");