allow range frame calls using range cache policies other than full

Signed-off-by: Richard Chien <[email protected]>
risingwavelabs · Feb 4, 2024 · a5b3395 · a5b3395
1 parent 1ca5ea4
commit a5b3395
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/stream/src/executor/over_window/general.rs b/src/stream/src/executor/over_window/general.rs
@@ -171,9 +171,7 @@ impl<S: StateStore> OverWindowExecutor<S> {
             .calls
             .iter()
             .any(|call| call.frame.bounds.is_unbounded());
-        // TODO(rc): only support full cache for `RANGE` frame for now, for the sake of simplicity
-        let has_range_frame = args.calls.iter().any(|call| call.frame.bounds.is_range());
-        let cache_policy = if has_unbounded_frame || has_range_frame {
+        let cache_policy = if has_unbounded_frame {
             // For unbounded frames, we finally need all entries of the partition in the cache,
             // so for simplicity we just use full cache policy for these cases.
             CachePolicy::Full