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

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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

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


[hidden email]