guoliubi...@foxmail.com 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吗
guoliubi...@foxmail.com