From ca46bd04eece6f5c37ecdff178b71434d537006f Mon Sep 17 00:00:00 2001
From: discord9 <discord9@163.com>
Date: Mon, 21 Apr 2025 17:25:11 +0800
Subject: [PATCH] chore: better logging

---
 src/flow/src/batching_mode/state.rs | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/src/flow/src/batching_mode/state.rs b/src/flow/src/batching_mode/state.rs
index d34ab8fbeb..4c6f608af9 100644
--- a/src/flow/src/batching_mode/state.rs
+++ b/src/flow/src/batching_mode/state.rs
@@ -17,8 +17,8 @@
 use std::collections::BTreeMap;
 use std::time::Duration;
 
+use common_telemetry::debug;
 use common_telemetry::tracing::warn;
-use common_telemetry::{debug, info};
 use common_time::Timestamp;
 use datatypes::value::Value;
 use session::context::QueryContextRef;
@@ -88,9 +88,11 @@ impl TaskState {
         if self.dirty_time_windows.windows.is_empty() {
             self.last_update_time + next_duration
         } else {
-            info!(
-                "Flow id = {}, still have {:?} dirty time window, execute immediately",
-                flow_id, self.dirty_time_windows.windows
+            debug!(
+                "Flow id = {}, still have {} dirty time window({:?}), execute immediately",
+                flow_id,
+                self.dirty_time_windows.windows.len(),
+                self.dirty_time_windows.windows
             );
             Instant::now()
         }