fix watermark test

risingwavelabs · Jul 19, 2024 · fb6b75e · fb6b75e
1 parent 4c382d9
commit fb6b75e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/stream/src/executor/watermark_filter.rs b/src/stream/src/executor/watermark_filter.rs
@@ -77,7 +77,7 @@ impl<S: StateStore> Execute for WatermarkFilterExecutor<S> {
         self.execute_inner().boxed()
     }
 }
-const UPDATE_GLOBAL_WATERMARK_FREQUENCY_WHEN_IDLE: usize = 10;
+const UPDATE_GLOBAL_WATERMARK_FREQUENCY_WHEN_IDLE: usize = 5;
 
 impl<S: StateStore> WatermarkFilterExecutor<S> {
     #[try_stream(ok = Message, error = StreamExecutorError)]