fmt

risingwavelabs · Jul 18, 2024 · 2a0642a · 2a0642a
1 parent a389507
commit 2a0642a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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