Apache Flink - 作業和調度

Scheduling： Flink中的執行資源通過任務槽(Task Slots)定義。每個TaskManager都有一個或多個任務槽，每個槽都可以運行一個並行任務管道(pipeline)。管道由多個連續的任務組成，例如第n個MapFunction並行實例和第n個ReduceFunction並行實例。Flink經常併發地執行連續的任務：對於流程序，這在任何情況下都會發生，對於批處理程序，它也經常發生

>>阅读原文<<