diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/backup/util/BackupClientUtil.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/backup/util/BackupClientUtil.java index f6cda23..c416a0f 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/backup/util/BackupClientUtil.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/backup/util/BackupClientUtil.java @@ -237,7 +237,7 @@ public final class BackupClientUtil { LOG.debug(tableDir.toString() + " is empty, remove it."); } } - outputFs.delete(new Path(targetDir), true); + outputFs.delete(new Path(targetDir, backupContext.getBackupId()), true); } catch (IOException e1) { LOG.error("Cleaning up backup data of " + backupContext.getBackupId() + " at " + backupContext.getTargetRootDir() + " failed due to " + e1.getMessage() + ".");