From 62e93d88fdede394917c5b03235fc0afbda89abd Mon Sep 17 00:00:00 2001 From: Noel Kwan Date: Wed, 6 Sep 2023 13:38:21 +0800 Subject: [PATCH] Use Default cache policy for OverWindow if missing --- src/stream/src/from_proto/over_window.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/stream/src/from_proto/over_window.rs b/src/stream/src/from_proto/over_window.rs index 3fa8929b4feb3..0ee5d6d8789ec 100644 --- a/src/stream/src/from_proto/over_window.rs +++ b/src/stream/src/from_proto/over_window.rs @@ -74,7 +74,9 @@ impl ExecutorBuilder for OverWindowExecutorBuilder { state_table, watermark_epoch: stream.get_watermark_epoch(), chunk_size: params.env.config().developer.chunk_size, - cache_policy: OverWindowCachePolicy::from_protobuf(node.get_cache_policy()?), + cache_policy: OverWindowCachePolicy::from_protobuf( + node.get_cache_policy().unwrap_or_default(), + ), }) .boxed()) }