You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by bu...@apache.org on 2017/07/19 16:04:41 UTC
[3/3] hbase git commit: HBASE-17648: HBase Table-level
synchronization fails between two secured(kerberized) cluster
HBASE-17648: HBase Table-level synchronization fails between two secured(kerberized) cluster
Signed-off-by: tedyu <yu...@gmail.com>
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/15dbb2d2
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/15dbb2d2
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/15dbb2d2
Branch: refs/heads/branch-1.3
Commit: 15dbb2d29b931f3e88644a00e621cfc83ed9e29c
Parents: 705a3ae
Author: Yi Liang <ea...@gmail.com>
Authored: Tue Feb 14 10:22:22 2017 -0800
Committer: Sean Busbey <bu...@apache.org>
Committed: Wed Jul 19 10:57:38 2017 -0500
----------------------------------------------------------------------
.../java/org/apache/hadoop/hbase/mapreduce/SyncTable.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/15dbb2d2/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/SyncTable.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/SyncTable.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/SyncTable.java
index b19b482..8727c71 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/SyncTable.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/SyncTable.java
@@ -143,7 +143,13 @@ public class SyncTable extends Configured implements Tool {
// would be nice to add an option for bulk load instead
}
-
+
+ // Obtain an authentication token, for the specified cluster, on behalf of the current user
+ if (sourceZkCluster != null) {
+ Configuration peerConf =
+ HBaseConfiguration.createClusterConf(job.getConfiguration(), sourceZkCluster);
+ TableMapReduceUtil.initCredentialsForCluster(job, peerConf);
+ }
return job;
}