Hi
     这个需求可以考虑用 processfunction[1] 来实现,window 的 state 只能给单独的 window 使用,其他
window 不能操作之前的 window 的 state
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/stream/operators/process_function.html#the-keyedprocessfunction
Best,
Congxian


[email protected] <[email protected]>
于2020年9月15日周二 下午4:53写道:

> 可以补吗? 比如我现在是1分钟的窗口,要是这一分种 没有message,那就以上一个窗口的数据作为这一窗口的数据。
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/

回复