chore: make some source log debug instead of info (#14225)

risingwavelabs · Jan 2, 2024 · 7c84d06 · 7c84d06
1 parent b38da9c
commit 7c84d06
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/stream/src/executor/source/fs_source_executor.rs b/src/stream/src/executor/source/fs_source_executor.rs
@@ -329,7 +329,7 @@ impl<S: StateStore> FsSourceExecutor<S> {
         // init in-memory split states with persisted state if any
         self.stream_source_core.init_split_state(boot_state.clone());
         let recover_state: ConnectorState = (!boot_state.is_empty()).then_some(boot_state);
-        tracing::info!(actor_id = self.actor_ctx.id, state = ?recover_state, "start with state");
+        tracing::debug!(actor_id = self.actor_ctx.id, state = ?recover_state, "start with state");
 
         let source_chunk_reader = self
             .build_stream_source_reader(&source_desc, recover_state)

diff --git a/src/stream/src/executor/source/source_executor.rs b/src/stream/src/executor/source/source_executor.rs
@@ -382,7 +382,7 @@ impl<S: StateStore> SourceExecutor<S> {
                     ..
                 }) => {
                     if let Some(splits) = splits.get(&self.actor_ctx.id) {
-                        tracing::info!(
+                        tracing::debug!(
                             "source exector: actor {:?} boot with splits: {:?}",
                             self.actor_ctx.id,
                             splits
@@ -414,7 +414,7 @@ impl<S: StateStore> SourceExecutor<S> {
         self.stream_source_core = Some(core);
 
         let recover_state: ConnectorState = (!boot_state.is_empty()).then_some(boot_state);
-        tracing::info!(actor_id = self.actor_ctx.id, state = ?recover_state, "start with state");
+        tracing::debug!(actor_id = self.actor_ctx.id, state = ?recover_state, "start with state");
         let source_chunk_reader = self
             .build_stream_source_reader(&source_desc, recover_state)
             .instrument_await("source_build_reader")