Repository: hbase Updated Branches: refs/heads/branch-1 403891723 -> b141603e2
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/b141603e Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/b141603e Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/b141603e Branch: refs/heads/branch-1 Commit: b141603e2e70c80d28d91eeadb8b584993f953b4 Parents: 4038917 Author: Yi Liang <easyliang...@gmail.com> Authored: Tue Feb 14 10:22:22 2017 -0800 Committer: tedyu <yuzhih...@gmail.com> Committed: Fri Feb 17 07:04:35 2017 -0800 ---------------------------------------------------------------------- .../main/java/org/apache/hadoop/hbase/mapreduce/SyncTable.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/b141603e/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 27518ca..32e3b00 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 @@ -144,6 +144,12 @@ 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; }
