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(