美文网首页
FLink任务结束时触发Timer的过程简记

FLink任务结束时触发Timer的过程简记

作者: 海边的贝壳林 | 来源:发表于2023-07-29 10:03 被阅读0次
image.png

顺着堆栈往下走,到了Window算子的父类AbstractStreamOperator中的processWatermark方法,对于timeServiceManager不为空的情况,要特别处理一下这个watermark。其实后面就是对于timeServiceManager所管理的所有timeService都处理一下这个watermark。


image.png

如果是到了最大的watermark,那就调用keySelected方法并且传了了null值。


image.png

注意这里的key是null值。


image.png image.png

相关文章

网友评论

      本文标题:FLink任务结束时触发Timer的过程简记

      本文链接:https://www.haomeiwen.com/subject/qpwrpdtx.html