Refactor logging in ClusterManager with tracing

risingwavelabs · Jan 30, 2024 · d95a062 · d95a062
1 parent b4897d6
commit d95a062
Showing 1 changed file with 4 additions and 2 deletions.
diff --git 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(