Tumble Window某个时间区间没数据的问题

Sat, 12 Dec 2020 21:43:45 -0800 

Flink 1.12.0版本，java代码做了如下处理
txnStream
        .window(TumblingEventTimeWindows.of(Time.seconds(3L)))
        .process(new NetValueAggregateFunction())
在某个3秒的区间没有数据的话，就不会进入process的function里，
是否有什么配置可以让每3秒必定进process的function吗


[email protected]

回复