Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
Tumble Window某个时间区间没数据的问题
Classic
List
Threaded
♦
♦
Locked
1 message
Lucas
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
Tumble Window某个时间区间没数据的问题
Flink 1.12.0版本,java代码做了如下处理
txnStream
.window(TumblingEventTimeWindows.of(Time.seconds(3L)))
.process(new NetValueAggregateFunction())
在某个3秒的区间没有数据的话,就不会进入process的function里,
是否有什么配置可以让每3秒必定进process的function吗
[hidden email]
Free forum by Nabble
Edit this page