AMBARI-13899. 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/6e69ef00 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/6e69ef00 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/6e69ef00 Branch: refs/heads/branch-dev-patch-upgrade Commit: 6e69ef00d39e5d803832d4f74aed9ba3e41bbeca Parents: b5ad10a Author: Sumit Mohanty <smoha...@hortonworks.com> Authored: Mon Nov 16 18:55:36 2015 -0800 Committer: Sumit Mohanty <smoha...@hortonworks.com> Committed: Mon Nov 16 18:55:36 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/6e69ef00/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/6e69ef00/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";
