Flink 調度

一.調度 Flink通過Task Slots來定義執行資源。每個TaskManager有一到task slot，每個task slot可以運行一條由多個並行task組成的流水線。這樣一條流水線由多個連續的task組成，比如並行度n的MapFunction和並行度爲n的ReduceFunction。需要注意的是Flink經常併發執行連續task，不僅在流式作業中到處都是，在批量作業中也很常見。 一個

>>阅读原文<<