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/
