Skip to content

Commit 99ecd5d

Browse files
authored
fix(streaming): handle missing cache_policy field in OverWindow (#12110)
1 parent 50792cc commit 99ecd5d

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/stream/src/from_proto/over_window.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,9 @@ impl ExecutorBuilder for OverWindowExecutorBuilder {
7575
watermark_epoch: stream.get_watermark_epoch(),
7676
metrics: params.executor_stats,
7777
chunk_size: params.env.config().developer.chunk_size,
78-
cache_policy: OverWindowCachePolicy::from_protobuf(node.get_cache_policy()?),
78+
cache_policy: OverWindowCachePolicy::from_protobuf(
79+
node.get_cache_policy().unwrap_or_default(),
80+
),
7981
})
8082
.boxed())
8183
}

0 commit comments

Comments
 (0)