Flink之Runtime核心機制剖析

本文將首先介紹 Flink Runtime 的整體架構以及 Job 的基本執行流程，然後介紹在這個過程中 Flink 是怎麼進行資源管理、作業調度以及錯誤恢復的。最後，本文還將簡要介紹 Flink Runtime 層當前正在進行的一些工作。 一、整體架構 Flink Runtime 整體架構 Flink 是可以運行在多種不同的環境中的，例如，它可以通過單進程多線程的方式直接運行，從而提供調試的能力

>>阅读原文<<