Repository: phoenix Updated Branches: refs/heads/4.0 3ef7df14c -> 40bc58a5a
PHOENIX-19 Enhance JDBC connection of Phoenix to support connecting to a Secure HBase cluster (Anil Gupta) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/40bc58a5 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/40bc58a5 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/40bc58a5 Branch: refs/heads/4.0 Commit: 40bc58a5a1aa5eeebb17e3d33c37b70997aaecb1 Parents: 3ef7df1 Author: James Taylor <jtay...@salesforce.com> Authored: Sun Jun 8 11:08:41 2014 -0700 Committer: James Taylor <jtay...@salesforce.com> Committed: Sun Jun 8 11:08:41 2014 -0700 ---------------------------------------------------------------------- .../org/apache/phoenix/query/ConnectionQueryServicesImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/40bc58a5/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java index 716ba3d..be118c5 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java @@ -255,8 +255,8 @@ public class ConnectionQueryServicesImpl extends DelegateQueryServices implement private void openConnection() throws SQLException { try { // check if we need to authenticate with kerberos - String clientKeytab = config.get(HBASE_CLIENT_KEYTAB); - String clientPrincipal = config.get(HBASE_CLIENT_PRINCIPAL); + String clientKeytab = this.getProps().get(HBASE_CLIENT_KEYTAB); + String clientPrincipal = this.getProps().get(HBASE_CLIENT_PRINCIPAL); if (clientKeytab != null && clientPrincipal != null) { logger.info("Trying to connect to a secure cluster with keytab:" + clientKeytab); UserGroupInformation.setConfiguration(config);
