You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by sm...@apache.org on 2015/11/17 17:32:01 UTC
ambari git commit: "AMBARI-13875. Support Impersonation for Hive
(Henning Kropp via smohanty)""
Repository: ambari
Updated Branches:
refs/heads/branch-2.1.2 4b53ffb73 -> bbc331af0
"AMBARI-13875. Support Impersonation for Hive (Henning Kropp via smohanty)""
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/bbc331af
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/bbc331af
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/bbc331af
Branch: refs/heads/branch-2.1.2
Commit: bbc331af097252a50159f56fea4464d381d086da
Parents: 4b53ffb
Author: Sumit Mohanty <sm...@hortonworks.com>
Authored: Tue Nov 17 08:30:31 2015 -0800
Committer: Sumit Mohanty <sm...@hortonworks.com>
Committed: Tue Nov 17 08:31:05 2015 -0800
----------------------------------------------------------------------
.../java/org/apache/ambari/view/hive/client/Connection.java | 6 ++++++
.../main/java/org/apache/ambari/view/hive/client/Utils.java | 1 +
2 files changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ambari/blob/bbc331af/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/Connection.java
----------------------------------------------------------------------
diff --git a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/Connection.java b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/Connection.java
index 0e42d99..d8210ba 100644
--- a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/Connection.java
+++ b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/Connection.java
@@ -476,6 +476,12 @@ public class Connection {
@Override
public TOpenSessionResp body() throws HiveClientException {
TOpenSessionReq openReq = new TOpenSessionReq();
+ Map<String, String> openConf = new HashMap<String, String>();
+ if(authParams.containsKey(Utils.HiveAuthenticationParams.HS2_PROXY_USER)){
+ openConf.put(Utils.HiveAuthenticationParams.HS2_PROXY_USER,
+ authParams.get(Utils.HiveAuthenticationParams.HS2_PROXY_USER));
+ }
+ openReq.setConfiguration(openConf);
try {
return client.OpenSession(openReq);
} catch (TException e) {
http://git-wip-us.apache.org/repos/asf/ambari/blob/bbc331af/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/Utils.java
----------------------------------------------------------------------
diff --git a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/Utils.java b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/Utils.java
index cada587..f9efc1c 100644
--- a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/Utils.java
+++ b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/Utils.java
@@ -68,6 +68,7 @@ public class Utils {
public static final String AUTH_SIMPLE = "noSasl";
public static final String AUTH_TOKEN = "delegationToken";
public static final String AUTH_USER = "user";
+ public static final String HS2_PROXY_USER = "hive.server2.proxy.user";
public static final String AUTH_PRINCIPAL = "principal";
public static final String AUTH_PASSWD = "password";
public static final String AUTH_KERBEROS_AUTH_TYPE = "kerberosAuthType";