diff --git a/src/flow/src/batching_mode/time_window.rs b/src/flow/src/batching_mode/time_window.rs index 795de2cd8c..4739994218 100644 --- a/src/flow/src/batching_mode/time_window.rs +++ b/src/flow/src/batching_mode/time_window.rs @@ -150,6 +150,8 @@ impl TimeWindowExpr { } } + // FAST PATH: if we have eval_time_original and eval_time_window_size, + // we can compute the bounds directly if let (Some(original), Some(window_size)) = (self.eval_time_original, self.eval_time_window_size) {