feat(stream): inform rate limit update for fsfetch executor (#20457)

Co-authored-by: Bohan Zhang <tabvision@bupt.icu>
risingwavelabs · Feb 11, 2025 · a517cae · a517cae
1 parent 77c80fb
commit a517cae
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/stream/src/executor/source/fs_fetch_executor.rs b/src/stream/src/executor/source/fs_fetch_executor.rs
@@ -259,7 +259,7 @@ impl<S: StateStore, Src: OpendalSource> FsFetchExecutor<S, Src> {
                                                     actor_to_apply.get(&self.actor_ctx.id)
                                                     && *new_rate_limit != self.rate_limit_rps
                                                 {
-                                                    tracing::debug!(
+                                                    tracing::info!(
                                                         "updating rate limit from {:?} to {:?}",
                                                         self.rate_limit_rps,
                                                         *new_rate_limit