hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From te...@apache.org
Subject hbase git commit: HBASE-17648: HBase Table-level synchronization fails between two secured(kerberized) cluster
Date Fri, 17 Feb 2017 15:03:58 GMT
Repository: hbase
Updated Branches:
  refs/heads/master 7763dd668 -> a2d2196e8


HBASE-17648: HBase Table-level synchronization fails between two secured(kerberized) cluster

Signed-off-by: tedyu <yuzhihong@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/a2d2196e
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/a2d2196e
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/a2d2196e

Branch: refs/heads/master
Commit: a2d2196e89f4228c01724eef09c92f82b33c32ed
Parents: 7763dd6
Author: Yi Liang <easyliangjob@gmail.com>
Authored: Tue Feb 14 10:22:22 2017 -0800
Committer: tedyu <yuzhihong@gmail.com>
Committed: Fri Feb 17 07:03:53 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/a2d2196e/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 574ec50..954194e 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;
   }
 


Mime
View raw message