chore: suppress storage log on back-pressure (#13221)

risingwavelabs · Nov 2, 2023 · f39d0ad · f39d0ad
1 parent 8b58861
commit f39d0ad
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/src/meta/src/hummock/manager/mod.rs b/src/meta/src/hummock/manager/mod.rs
@@ -556,7 +556,7 @@ impl HummockManager {
         versioning_guard.write_limit =
             calc_new_write_limits(configs, HashMap::new(), &versioning_guard.current_version);
         trigger_write_stop_stats(&self.metrics, &versioning_guard.write_limit);
-        tracing::info!("Hummock stopped write: {:#?}", versioning_guard.write_limit);
+        tracing::debug!("Hummock stopped write: {:#?}", versioning_guard.write_limit);
 
         Ok(())
     }

diff --git a/src/meta/src/hummock/manager/versioning.rs b/src/meta/src/hummock/manager/versioning.rs
@@ -254,7 +254,7 @@ impl HummockManager {
         if new_write_limits == guard.write_limit {
             return false;
         }
-        tracing::info!("Hummock stopped write is updated: {:#?}", new_write_limits);
+        tracing::debug!("Hummock stopped write is updated: {:#?}", new_write_limits);
         trigger_write_stop_stats(&self.metrics, &new_write_limits);
         guard.write_limit = new_write_limits;
         self.env

diff --git a/src/storage/src/hummock/write_limiter.rs b/src/storage/src/hummock/write_limiter.rs
@@ -80,13 +80,13 @@ impl WriteLimiter {
                 Some(reason) => {
                     if first_block_msg {
                         first_block_msg = false;
-                        tracing::warn!(
+                        tracing::debug!(
                             "write to table {} is blocked: {}",
                             table_id.table_id,
                             reason,
                         );
                     } else {
-                        tracing::warn!(
+                        tracing::debug!(
                             "write limiter is updated, but write to table {} is still blocked: {}",
                             table_id.table_id,
                             reason,
@@ -99,6 +99,6 @@ impl WriteLimiter {
             }
             notified.await;
         }
-        tracing::info!("write to table {} is unblocked", table_id.table_id,);
+        tracing::debug!("write to table {} is unblocked", table_id.table_id,);
     }
 }