From f1ddf6c3dab1330a2d0117b244d8a48f352abdcb Mon Sep 17 00:00:00 2001 From: Duo Zhang Date: Tue, 18 Nov 2025 17:11:46 +0800 Subject: [PATCH] HBASE-29718 [hbase-operator-tools] Use BulkLoadHFiles instead of LoadIncrementalHFiles in hbase-tools --- .../org/apache/hbase/MissingRegionDirsRepairTool.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/hbase-tools/src/main/java/org/apache/hbase/MissingRegionDirsRepairTool.java b/hbase-tools/src/main/java/org/apache/hbase/MissingRegionDirsRepairTool.java index 0d9e892fba..9bba5adc23 100644 --- a/hbase-tools/src/main/java/org/apache/hbase/MissingRegionDirsRepairTool.java +++ b/hbase-tools/src/main/java/org/apache/hbase/MissingRegionDirsRepairTool.java @@ -30,7 +30,7 @@ import org.apache.hadoop.hbase.client.Admin; import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.ConnectionFactory; -import org.apache.hadoop.hbase.tool.LoadIncrementalHFiles; +import org.apache.hadoop.hbase.tool.BulkLoadHFiles; import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.util.ToolRunner; import org.slf4j.Logger; @@ -45,12 +45,12 @@ public class MissingRegionDirsRepairTool extends Configured implements org.apach private Configuration conf; private HBCK2 hbck; - private LoadIncrementalHFiles bulkLoad; + private BulkLoadHFiles bulkLoad; public MissingRegionDirsRepairTool(Configuration conf) { this.conf = conf; this.hbck = new HBCK2(conf); - this.bulkLoad = new LoadIncrementalHFiles(conf); + this.bulkLoad = BulkLoadHFiles.create(conf); } @Override @@ -102,7 +102,7 @@ public int run(String[] strings) throws Exception { } }); LOG.info("Calling bulk load for: " + tblPath.toUri().getRawPath()); - bulkLoad.run(bulkload.toUri().getRawPath(), t); + bulkLoad.bulkLoad(t, bulkload); } catch (IOException e) { LOG.error("Error trying to create temp dir for sideline files: ", e); }