Re: flink timerservice注册的timer定时器只有少部分触发

Thu, 06 Aug 2020 20:40:27 -0700 

Hi
   对于 event time 的处理来说，不建议注册 timer 的时候使用 System.currentTimeMillis()
这种系统时间，这两个时间可能会不一样，可以使用 TimerService 中的 currentWatermark 表示当前的 event time

Best,
Congxian


jsqf <[email protected]> 于2020年8月6日周四 下午9:53写道：

> 试试 重写 onTimer 方法
> 可以参考
>
> https://github.com/JSQF/flink10_learn/blob/master/src/main/scala/com/yyb/flink10/DataStream/ProcessFunction/OperatorProcessFunctionDemo.java
>
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>

回复