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


guoliubi...@foxmail.com

Reply via email to