This is an automated email from the ASF dual-hosted git repository. rmattingly pushed a commit to branch HBASE-29239-branch-2.6 in repository https://gitbox.apache.org/repos/asf/hbase.git
commit c3e7485db04cac2e3bf2be039ed5403fba906299 Author: Hernan Romer <[email protected]> AuthorDate: Thu Apr 3 10:20:03 2025 -0400 HBASE-29239: Subsequent runs of re-splitting HFiles can fail because we don't cleanup the MR directory (#6876) Co-authored-by: Hernan Gelaf-Romer <[email protected]> Signed-off-by: Ray Mattingly <[email protected]> --- .../apache/hadoop/hbase/backup/impl/IncrementalTableBackupClient.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/IncrementalTableBackupClient.java b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/IncrementalTableBackupClient.java index ab1163aeed8..885f942c77a 100644 --- a/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/IncrementalTableBackupClient.java +++ b/hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/IncrementalTableBackupClient.java @@ -219,6 +219,9 @@ public class IncrementalTableBackupClient extends TableBackupClient { result = player.run(args); } catch (Exception e) { LOG.error("Failed to run MapReduceHFileSplitterJob", e); + // Delete the bulkload directory if we fail to run the HFile splitter job for any reason + // as it might be re-tried + deleteBulkLoadDirectory(); throw new IOException(e); }
