[kudu] branch master updated: [tools] correct rebalancer's initial status message

[alexey]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 9e952ad  [tools] correct rebalancer's initial status message
9e952ad is described below

commit 9e952ad9d87eefc9ef840cd3edbdd62dd9f0243e
Author: Alexey Serbin <ale...@apache.org>
AuthorDate: Mon Mar 7 12:27:35 2022 -0800

    [tools] correct rebalancer's initial status message
    
    I noticed that the 'kudu cluster rebalance' tool was reporting that
    it had been '...running whole-cluster rebalancing...' even when running
    with a particular set of tables to rebalance, i.e. not a whole-cluster
    rebalancing by any means if there is more than one table in a cluster.
    
    This patch fixes the issue.
    
    Change-Id: Ic224a07f9ce9ed3ca9a447022f183b799a1bebee
    Reviewed-on: http://gerrit.cloudera.org:8080/18297
    Reviewed-by: Abhishek Chennaka <achenn...@cloudera.com>
    Tested-by: Alexey Serbin <ale...@apache.org>
    Reviewed-by: Andrew Wong <aw...@cloudera.com>
---
 src/kudu/tools/rebalancer_tool.cc | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/kudu/tools/rebalancer_tool.cc 
b/src/kudu/tools/rebalancer_tool.cc
index b69ca05..8c53b3e 100644
--- a/src/kudu/tools/rebalancer_tool.cc
+++ b/src/kudu/tools/rebalancer_tool.cc
@@ -39,6 +39,7 @@
 #include "kudu/gutil/basictypes.h"
 #include "kudu/gutil/map-util.h"
 #include "kudu/gutil/port.h"
+#include "kudu/gutil/strings/join.h"
 #include "kudu/gutil/strings/substitute.h"
 #include "kudu/master/master.pb.h"
 #include "kudu/rebalance/cluster_status.h"
@@ -190,7 +191,12 @@ Status RebalancerTool::Run(RunStatus* result_status, 
size_t* moves_count) {
   }
   if (ts_id_by_location.size() == 1) {
     const auto& location = ts_id_by_location.cbegin()->first;
-    LOG(INFO) << "running whole-cluster rebalancing";
+    const auto& table_filters = config_.table_filters;
+    const auto& msg = table_filters.empty()
+        ? "running whole-cluster rebalancing"
+        : Substitute("running rebalancing for tables: $0",
+                     JoinStrings(table_filters, ","));
+    LOG(INFO) << msg;
     IntraLocationRunner runner(
         this, config_.ignored_tservers, config_.max_moves_per_server, 
deadline, location);
     RETURN_NOT_OK(runner.Init(config_.master_addresses));