(hbase-operator-tools) branch master updated: HBASE-29718 [hbase-operator-tools] Use BulkLoadHFiles instead of LoadIncrementalHFiles in hbase-tools (#157)

[zhangduo]

This is an automated email from the ASF dual-hosted git repository.

zhangduo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase-operator-tools.git


The following commit(s) were added to refs/heads/master by this push:
     new f8a707e  HBASE-29718 [hbase-operator-tools] Use BulkLoadHFiles instead 
of LoadIncrementalHFiles in hbase-tools (#157)
f8a707e is described below

commit f8a707e155baa74fc9791895d8ae538d1309e1b0
Author: Duo Zhang <zhang...@apache.org>
AuthorDate: Thu Nov 20 09:39:52 2025 +0800

    HBASE-29718 [hbase-operator-tools] Use BulkLoadHFiles instead of 
LoadIncrementalHFiles in hbase-tools (#157)
    
    Signed-off-by: Wellington Chevreuil <wchevre...@apache.org>
    Signed-off-by: Nihal Jain <nihalj...@apache.org>
---
 .../main/java/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 0d9e892..9bba5ad 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.TableName;
 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 class MissingRegionDirsRepairTool extends Configured 
implements org.apach
               }
             });
             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);
           }