HBASE-17648: HBase Table-level synchronization fails between two secured(kerberized) cluster
Signed-off-by: tedyu <yuzhih...@gmail.com> Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/5839056c Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/5839056c Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/5839056c Branch: refs/heads/branch-1.2 Commit: 5839056ce10b68123d2964479927fc28946db059 Parents: cb02b72 Author: Yi Liang <easyliang...@gmail.com> Authored: Tue Feb 14 10:22:22 2017 -0800 Committer: Sean Busbey <bus...@apache.org> Committed: Wed Jul 19 11:05:31 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/5839056c/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; }
