diff --git spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java index 03e773a..70add1c 100644 --- spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java +++ spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java @@ -435,7 +435,8 @@ public void run() { try { String currentUser = Utils.getUGI().getShortUserName(); // do not do impersonation in CLI mode - if (!currentUser.equals(System.getProperty("user.name"))) { + if (!currentUser.equals(System.getProperty("user.name")) + || "kerberos".equals(hiveConf.get(HADOOP_SECURITY_AUTHENTICATION))) { LOG.info("Attempting impersonation of " + currentUser); argv.add("--proxy-user"); argv.add(currentUser);