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 3280dfb..2b6c906 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 @@ -65,6 +65,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 @@ -83,6 +84,7 @@ public class FullTableBackupProcedure private String backupId; private List tableList; private String targetRootDir; + private UserGroupInformation user; HashMap newTimestamps = null; private BackupManager backupManager; @@ -105,6 +107,8 @@ public class FullTableBackupProcedure if (tableList == null || tableList.isEmpty()) { this.tableList = new ArrayList<>(backupInfo.getTables()); } + this.user = env.getRequestUser().getUGI(); + this.setOwner(this.user.getShortUserName()); } @Override