From 51954359416b107ce5eda6cb710449edc98ab0e6 Mon Sep 17 00:00:00 2001 From: huzheng Date: Thu, 4 Jan 2018 11:47:20 +0800 Subject: [PATCH] HBASE-18452 VerifyReplication by Snapshot should cache HDFS token before submit job for kerberos env --- .../hadoop/hbase/mapreduce/replication/VerifyReplication.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java index 035086e069e..9065f4e80c3 100644 --- a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java +++ b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java @@ -28,6 +28,7 @@ import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hbase.Abortable; import org.apache.hadoop.hbase.HBaseConfiguration; +import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.ConnectionFactory; @@ -428,7 +429,7 @@ public class VerifyReplication extends Configured implements Tool { conf.set(NAME + ".peerHBaseRootAddress", peerHBaseRootAddress); // This is to create HDFS delegation token for peer cluster in case of secured - conf.setStrings(MRJobConfig.JOB_NAMENODES, peerFSAddress); + conf.setStrings(MRJobConfig.JOB_NAMENODES, peerFSAddress, conf.get(HConstants.HBASE_DIR)); } Job job = Job.getInstance(conf, conf.get(JOB_NAME_CONF_KEY, NAME + "_" + tableName));