Flink-跟着問題讀源碼：CheckPoint超時問題總結

最近一段時間處理的業務數據量的增長和處理流程的複雜性，導致flink實時作業不僅僅侷限於結果正確，更多的精力放在了性能優化上，接下來對近期CheckPoint時長優化進行總結。 我們都知道checkpoint的重要性，整體過程如下： JobManager 向 Source 算子發送 Barrier ，初始化 Checkpoint，即JM向Source發起Trigger操作； 各個Source 算子

>>阅读原文<<