95-170-044-源碼-Time-flink時間Processing Time源碼分析

1.世界 2.概述 ​ flink 中Processing Time也就是處理時間在watermark定時生成、ProcessFunction中定時器與時間類型的窗口中都有使用，但是其內部是如何實現註冊定時器、如何調用、如何容錯保證在任務掛掉在下次重啓仍然能夠觸發任務執行，都是我們今天的主題。首先需要了解一下在flink內部時間系統是由哪些類來共同完成這件事，下面畫了一個簡易的類關係圖： 3.Ab

>>阅读原文<<