From d95a06218b04649343ddd57427ef3f7374514e9c Mon Sep 17 00:00:00 2001 From: Shanicky Chen Date: Tue, 30 Jan 2024 18:41:04 +0800 Subject: [PATCH] Refactor logging in ClusterManager with `tracing` --- src/meta/src/manager/cluster.rs | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/meta/src/manager/cluster.rs b/src/meta/src/manager/cluster.rs index 2712a83632d92..e0d09cc1adb65 100644 --- a/src/meta/src/manager/cluster.rs +++ b/src/meta/src/manager/cluster.rs @@ -134,9 +134,11 @@ impl ClusterManager { let mut new_worker = worker.clone(); match old_worker_parallelism.cmp(&new_worker_parallelism) { Ordering::Less => { - println!( + tracing::info!( "worker {} parallelism updated from {} to {}", - new_worker.worker_node.id, old_worker_parallelism, new_worker_parallelism + new_worker.worker_node.id, + old_worker_parallelism, + new_worker_parallelism ); let parallel_units = self .generate_cn_parallel_units(