image.png
顺着堆栈往下走，到了Window算子的父类AbstractStreamOperator中的processWatermark方法，对于timeServiceManager不为空的情况，要特别处理一下这个watermark。其实后面就是对于timeServiceManager所管理的所有timeService都处理一下这个watermark。
image.png
如果是到了最大的watermark，那就调用keySelected方法并且传了了null值。
image.png
注意这里的key是null值。
image.png
image.png
