You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by br...@apache.org on 2015/02/27 23:49:30 UTC
svn commit: r1662841 -
/hive/branches/spark/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java
Author: brock
Date: Fri Feb 27 22:49:29 2015
New Revision: 1662841
URL: http://svn.apache.org/r1662841
Log:
HIVE-9803 - SparkClientImpl should not attempt impersonation in CLI mode [Spark Branch] (Brock via Chao)
Modified:
hive/branches/spark/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java
Modified: hive/branches/spark/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java
URL: http://svn.apache.org/viewvc/hive/branches/spark/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java?rev=1662841&r1=1662840&r2=1662841&view=diff
==============================================================================
--- hive/branches/spark/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java (original)
+++ hive/branches/spark/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java Fri Feb 27 22:49:29 2015
@@ -352,9 +352,14 @@ class SparkClientImpl implements SparkCl
}
if (hiveConf.getBoolVar(HiveConf.ConfVars.HIVE_SERVER2_ENABLE_DOAS)) {
- argv.add("--proxy-user");
try {
- argv.add(Utils.getUGI().getShortUserName());
+ String currentUser = Utils.getUGI().getShortUserName();
+ // do not do impersonation in CLI mode
+ if (!currentUser.equals(System.getProperty("user.name"))) {
+ LOG.info("Attempting impersonation of " + currentUser);
+ argv.add("--proxy-user");
+ argv.add(currentUser);
+ }
} catch (Exception e) {
String msg = "Cannot obtain username: " + e;
throw new IllegalStateException(msg, e);
@@ -385,7 +390,7 @@ class SparkClientImpl implements SparkCl
argv.add(String.format("%s=%s", hiveSparkConfKey, value));
}
- LOG.debug("Running client driver with argv: {}", Joiner.on(" ").join(argv));
+ LOG.info("Running client driver with argv: {}", Joiner.on(" ").join(argv));
ProcessBuilder pb = new ProcessBuilder(argv.toArray(new String[argv.size()]));
if (isTesting != null) {