diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/backup/master/FullTableBackupProcedure.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/backup/master/FullTableBackupProcedure.java index 7c832e4..8175837 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/backup/master/FullTableBackupProcedure.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/backup/master/FullTableBackupProcedure.java @@ -67,6 +67,7 @@ import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.SnapshotDescriptio import org.apache.hadoop.hbase.snapshot.SnapshotDescriptionUtils; import org.apache.hadoop.hbase.util.EnvironmentEdgeManager; import org.apache.hadoop.hbase.util.FSUtils; +import org.apache.hadoop.security.UserGroupInformation; @InterfaceAudience.Private public class FullTableBackupProcedure @@ -85,6 +86,7 @@ public class FullTableBackupProcedure private String backupId; private List tableList; private String targetRootDir; + private UserGroupInformation user; HashMap newTimestamps = null; private BackupManager backupManager; @@ -107,6 +109,8 @@ public class FullTableBackupProcedure if (tableList == null || tableList.isEmpty()) { this.tableList = new ArrayList<>(backupContext.getTables()); } + this.user = env.getRequestUser().getUGI(); + this.setOwner(this.user.getShortUserName()); } @Override diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/backup/master/IncrementalTableBackupProcedure.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/backup/master/IncrementalTableBackupProcedure.java index 05a63ce..b74c16e 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/backup/master/IncrementalTableBackupProcedure.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/backup/master/IncrementalTableBackupProcedure.java @@ -53,6 +53,7 @@ import org.apache.hadoop.hbase.procedure2.StateMachineProcedure; import org.apache.hadoop.hbase.protobuf.generated.BackupProtos; import org.apache.hadoop.hbase.protobuf.generated.BackupProtos.IncrementalTableBackupState; import org.apache.hadoop.hbase.protobuf.generated.BackupProtos.ServerTimestamp; +import org.apache.hadoop.security.UserGroupInformation; @InterfaceAudience.Private public class IncrementalTableBackupProcedure @@ -65,6 +66,7 @@ public class IncrementalTableBackupProcedure private String backupId; private List tableList; private String targetRootDir; + private UserGroupInformation user; HashMap newTimestamps = null; private BackupManager backupManager; @@ -84,6 +86,8 @@ public class IncrementalTableBackupProcedure this.targetRootDir = targetRootDir; backupContext = backupManager.createBackupContext(backupId, BackupType.INCREMENTAL, tableList, targetRootDir, workers, (int)bandwidth); + this.user = env.getRequestUser().getUGI(); + this.setOwner(this.user.getShortUserName()); } @Override