You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by wi...@apache.org on 2013/02/01 05:53:25 UTC
git commit: FLUME-1890. Flume should set the hbase keytab and
principal in HBase conf object
Updated Branches:
refs/heads/trunk f5d31f7a6 -> 001b38240
FLUME-1890. Flume should set the hbase keytab and principal in HBase conf object
(Hari Shreedharan via Will McQueen)
Project: http://git-wip-us.apache.org/repos/asf/flume/repo
Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/001b3824
Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/001b3824
Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/001b3824
Branch: refs/heads/trunk
Commit: 001b3824020c5ad36a965d515061353627923bdc
Parents: f5d31f7
Author: Will McQueen <wi...@cloudera.com>
Authored: Thu Jan 31 20:46:30 2013 -0800
Committer: Will McQueen <wi...@cloudera.com>
Committed: Thu Jan 31 20:52:55 2013 -0800
----------------------------------------------------------------------
.../flume/sink/hbase/HBaseSinkSecurityManager.java | 6 +++++-
1 files changed, 5 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flume/blob/001b3824/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HBaseSinkSecurityManager.java
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HBaseSinkSecurityManager.java b/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HBaseSinkSecurityManager.java
index 8bf0509..762fce9 100644
--- a/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HBaseSinkSecurityManager.java
+++ b/flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HBaseSinkSecurityManager.java
@@ -41,6 +41,8 @@ public class HBaseSinkSecurityManager {
* this can just be volatile, no need of Atomic reference.
*/
private volatile static KerberosUser loggedInUser;
+ private static final String FLUME_KEYTAB_KEY = "flume.keytab.key";
+ private static final String FLUME_PRINCIPAL_KEY = "flume.principal.key";
private static final Logger LOG =
LoggerFactory.getLogger(HBaseSinkSecurityManager.class);
@@ -119,7 +121,9 @@ public class HBaseSinkSecurityManager {
if (hostname == null || hostname.isEmpty()) {
hostname = InetAddress.getLocalHost().getCanonicalHostName();
}
- User.login(conf, kerberosKeytab, principal, hostname);
+ conf.set(FLUME_KEYTAB_KEY, kerberosKeytab);
+ conf.set(FLUME_PRINCIPAL_KEY, principal);
+ User.login(conf, FLUME_KEYTAB_KEY, FLUME_PRINCIPAL_KEY, hostname);
hbaseUser = User.create(UserGroupInformation.getLoginUser());
loggedInUser = newUser;
//TODO: Set the loggedInUser to the current user.