refactor: reduce periodical logs (#18080)

Signed-off-by: xxchan <[email protected]>
risingwavelabs · Aug 19, 2024 · 1699b3e · 1699b3e
1 parent d16847d
commit 1699b3e
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/ci/scripts/e2e-source-test.sh b/ci/scripts/e2e-source-test.sh
@@ -130,7 +130,7 @@ echo "> inserted new rows into postgres"
 
 # start cluster w/o clean-data
 unset RISINGWAVE_CI
-export RUST_LOG="events::stream::message::chunk=trace,risingwave_stream=debug,risingwave_batch=info,risingwave_storage=info" \
+export RUST_LOG="risingwave_stream=debug,risingwave_batch=info,risingwave_storage=info" \
 
 risedev dev ci-1cn-1fe-with-recovery
 echo "> wait for cluster recovery finish"

diff --git a/src/meta/src/barrier/mod.rs b/src/meta/src/barrier/mod.rs
@@ -309,7 +309,7 @@ impl CheckpointControl {
             );
         }
 
-        debug!(
+        tracing::trace!(
             prev_epoch = command_ctx.prev_epoch.value().0,
             ?jobs_to_wait,
             "enqueue command"
@@ -354,7 +354,7 @@ impl CheckpointControl {
     fn barrier_collected(&mut self, resp: BarrierCompleteResponse) {
         let worker_id = resp.worker_id;
         let prev_epoch = resp.epoch;
-        debug!(
+        tracing::trace!(
             worker_id,
             prev_epoch,
             partial_graph_id = resp.partial_graph_id,
@@ -1005,7 +1005,7 @@ impl GlobalBarrierManager {
             BarrierKind::Barrier
         };
 
-        debug!(prev_epoch = prev_epoch.value().0, "inject barrier");
+        tracing::trace!(prev_epoch = prev_epoch.value().0, "inject barrier");
 
         // Collect the jobs to finish
         if let (BarrierKind::Checkpoint(_), Command::Plain(None)) = (&kind, &command)
@@ -1206,7 +1206,7 @@ impl GlobalBarrierManagerContext {
         mut finished_jobs: Vec<TrackingJob>,
         backfill_pinned_log_epoch: HashMap<TableId, (u64, HashSet<TableId>)>,
     ) -> MetaResult<Option<HummockVersionStats>> {
-        debug!(
+        tracing::trace!(
             prev_epoch = node.command_ctx.prev_epoch.value().0,
             kind = ?node.command_ctx.kind,
             "complete barrier"

diff --git a/src/storage/hummock_sdk/src/compaction_group/hummock_version_ext.rs b/src/storage/hummock_sdk/src/compaction_group/hummock_version_ext.rs
@@ -565,7 +565,7 @@ impl HummockVersion {
             && self.visible_table_committed_epoch() < version_delta.visible_table_committed_epoch()
         {
             is_commit_epoch = true;
-            warn!("max committed epoch bumped but no table committed epoch is changed");
+            tracing::trace!("max committed epoch bumped but no table committed epoch is changed");
         }
 
         // apply to `levels`, which is different compaction groups