diff --git a/src/stream/src/executor/watermark_filter.rs b/src/stream/src/executor/watermark_filter.rs
index 90ff08dd5f56e..2d8e7ad7676e6 100644
--- a/src/stream/src/executor/watermark_filter.rs
+++ b/src/stream/src/executor/watermark_filter.rs
@@ -262,7 +262,9 @@ impl<S: StateStore> WatermarkFilterExecutor<S> {
                         if idle_input {
                             barrier_num_during_idle += 1;
 
-                            if barrier_num_during_idle == UPDATE_GLIOBAL_WATERMARK_FREQUENCY_WHEN_IDLE {
+                            if barrier_num_during_idle
+                                == UPDATE_GLIOBAL_WATERMARK_FREQUENCY_WHEN_IDLE
+                            {
                                 barrier_num_during_idle = 0;
                                 // Align watermark
                                 // NOTE(st1page): Should be `NoWait` because it could lead to a degradation of concurrent checkpoint situations, as it would require waiting for the previous epoch