95-170-044-源码-Time-flink时间Processing Time源码分析

1.世界 2.概述 ​ flink 中Processing Time也就是处理时间在watermark定时生成、ProcessFunction中定时器与时间类型的窗口中都有使用，但是其内部是如何实现注册定时器、如何调用、如何容错保证在任务挂掉在下次重启仍然能够触发任务执行，都是我们今天的主题。首先需要了解一下在flink内部时间系统是由哪些类来共同完成这件事，下面画了一个简易的类关系图： 3.Ab

>>阅读原文<<