关于Flink Process Function事件时间行为的技术咨询

问题1解答 #

• 你的理解完全正确。Flink的事件处理逻辑是先执行processElement处理业务逻辑，之后才会基于当前事件的时间戳更新Watermark。当T2时刻的第二个事件到达时，系统会优先调用processElement更新CountWithTimestamp的lastModified为T2，完成状态更新后才会计算并推进Watermark；当Watermark推进到定时器的触发时间阈值时，才会触发之前注册的onTimer方法。

问题2解答 #

• 如果这种场景持续重复（即每次定时器触发前，同一个key的新事件都会到达），那么确实始终无法触发输出。原因在于每次新事件到达都会先执行processElement，将lastModified更新为最新的事件时间T2、T3……后续定时器触发时，会发现lastModified已经远晚于定时器的触发时间，导致输出条件（比如判断lastModified是否等于定时器对应的状态时间）不满足，从而不会输出结果。只有当某个时间段内没有该key的新事件到达，Watermark推进到超过定时器触发时间，且lastModified未被更新时，onTimer才会执行并输出结果。

内容的提问来源于stack exchange，提问作者Yank Leo