mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-06-04 05:53:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

tablets: load_balancer: Log table load stats after each migration

Browse Source
This commit is contained in:
Tomasz Grabiec
2024-06-26 09:52:04 +02:00
parent b8996a0f59
commit ae7fd80554
1 changed files with 31 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
service/tablet_allocator.cc
View File

@@ -1347,6 +1347,33 @@ public:
co_return min_candidate;
}
future<> log_table_load(node_load_map& nodes, table_id table) {
size_t total_load = 0;
size_t shard_count = 0;
size_t max_shard_load = 0;
for (auto&& [host, node] : nodes) {
if (node.drained) {
continue;
}
shard_count += node.shard_count;
size_t this_node_max_shard_load = 0;
size_t node_load = 0;
for (shard_id shard = 0; shard < node.shard_count; shard++) {
co_await coroutine::maybe_yield();
auto load = node.shards[shard].tablet_count_per_table[table];
total_load += load;
node_load += load;
max_shard_load = std::max(max_shard_load, load);
this_node_max_shard_load = std::max(this_node_max_shard_load, load);
}
lblogger.debug("Load on host {} for table {}: total={}, max={}", host, table, node_load, this_node_max_shard_load);
}
auto avg_load = double(total_load) / shard_count;
auto overcommit = max_shard_load / avg_load;
lblogger.debug("Table {} shard overcommit: {}", table, overcommit);
}
future<migration_plan> make_internode_plan(const dc_name& dc, node_load_map& nodes,
const std::unordered_set<host_id>& nodes_to_drain,
host_id target) {
@@ -1616,6 +1643,10 @@ public:
push_back_node_candidate.cancel();
nodes_by_load.pop_back();
}
if (lblogger.is_enabled(seastar::log_level::debug)) {
co_await log_table_load(nodes, source_tablet.table);
}
}
if (plan.size() == batch_size) {