diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/ExportSnapshot.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/ExportSnapshot.java index 9cdd57a..5d9b100 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/ExportSnapshot.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/ExportSnapshot.java @@ -622,6 +622,9 @@ public final class ExportSnapshot extends Configured implements Tool { inputFsToken.acquireDelegationToken(inputFs); outputFsToken.acquireDelegationToken(outputFs); + job.getCredentials().addToken(new Text(inputFsToken.getRenewer()), inputFsToken.getUserToken()); + job.getCredentials().addToken(new Text(outputFsToken.getRenewer()), outputFsToken.getUserToken()); + // Run the MR Job if (!job.waitForCompletion(true)) { // TODO: Replace the fixed string with job.getStatus().getFailureInfo()