(hbase) branch master updated: HBASE-29909 RegionMover ignores configuration passed via -D on the command line (#7767)

[junegunn]

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

junegunn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git


The following commit(s) were added to refs/heads/master by this push:
     new 8c3ceda5968 HBASE-29909 RegionMover ignores configuration passed via 
-D on the command line (#7767)
8c3ceda5968 is described below

commit 8c3ceda59681a019eb40c876dce684d6462c01a2
Author: Junegunn Choi <juneg...@apache.org>
AuthorDate: Tue Jun 9 08:51:34 2026 +0900

    HBASE-29909 RegionMover ignores configuration passed via -D on the command 
line (#7767)
    
    Signed-off-by: Charles Connell <cconn...@apache.org>
---
 .../main/java/org/apache/hadoop/hbase/util/RegionMover.java    | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionMover.java 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionMover.java
index 5f7e62bd5bc..2c0d1fbd3ee 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionMover.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionMover.java
@@ -187,7 +187,11 @@ public class RegionMover extends AbstractHBaseTool 
implements Closeable {
      * Creates a new configuration and sets region mover specific overrides
      */
     private static Configuration createConf() {
-      Configuration conf = HBaseConfiguration.create();
+      final Configuration conf = HBaseConfiguration.create();
+      return overrideConf(conf);
+    }
+
+    private static Configuration overrideConf(Configuration conf) {
       conf.setInt("hbase.client.prefetch.limit", 1);
       conf.setInt("hbase.client.pause", 500);
       conf.setInt("hbase.client.retries.number", 100);
@@ -209,7 +213,7 @@ public class RegionMover extends AbstractHBaseTool 
implements Closeable {
       }
       this.filename = defaultDir + File.separator + 
System.getProperty("user.name") + this.hostname
         + ":" + Integer.toString(this.port);
-      this.conf = conf;
+      this.conf = overrideConf(new Configuration(conf));
     }
 
     /**
@@ -948,7 +952,7 @@ public class RegionMover extends AbstractHBaseTool 
implements Closeable {
   @Override
   protected void processOptions(CommandLine cmd) {
     String hostname = cmd.getOptionValue("r");
-    rmbuilder = new RegionMoverBuilder(hostname);
+    rmbuilder = new RegionMoverBuilder(hostname, getConf());
     this.loadUnload = cmd.getOptionValue("o").toLowerCase(Locale.ROOT);
     if (cmd.hasOption('m')) {
       rmbuilder.maxthreads(Integer.parseInt(cmd.getOptionValue('m')));