1.3.1　Flink系統架構

Flink可以運行在多種不同的環境中，例如，它可以通過單進程多線程的方式直接運行，從而提供調試的能力。它也可以運行在YARN或者K8S這種資源管理系統上，也可以在各種云環境中執行。

Flink的整體系統架構如圖1-7所示。

圖1-7　Apache Flink的系統架構

針對不同的執行環境，Flink提供了一套統一的分布式作業執行引擎，也就是Flink運行時層。Flink在運行時層之上提供了DataStream和DataSet兩套API，分別用來編寫流作業與批作業，以及一組更高級的API庫來簡化特定作業的編寫（例如用于復雜事件處理的CEP庫）。