chore(cherry-pick): handle missing cache_policy field in OverWindow (#…

…12116)
risingwavelabs · Sep 6, 2023 · 27a7348 · 27a7348
1 parent 4865ed6
commit 27a7348
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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())
     }