2.概述
在 Flink 中,計算資源的是以 Slot 作為基本機關進行配置設定的。本文将對 Flink 中計算資源的管理機制加以分析。
3. Task Slot 的基本概念
我們在前面的文章中了解了 Flink 叢集的啟動流程。在 Flink 叢集中,每個 TaskManager 都是一個單獨的 JVM 程序(非 MiniCluster 模式),并且在一個 TaskManager 中可能運作多個子任務,這些子任務都在各自獨立的線程中運作。為了控制一個 TaskManager 中可以運作的任務的數量,引入了 Task Slot 的概念。
看這個圖,假設一個流任務是這樣的
然後對應的槽位可能是這樣的