天天看點

95-280-035-源碼-資源管理-計算資源管理-TaskSlot2.概述3. Task Slot 的基本概念

95-280-035-源碼-資源管理-計算資源管理-TaskSlot2.概述3. Task Slot 的基本概念

2.概述

在 Flink 中,計算資源的是以 Slot 作為基本機關進行配置設定的。本文将對 Flink 中計算資源的管理機制加以分析。

3. Task Slot 的基本概念

​ 我們在前面的文章中了解了 Flink 叢集的啟動流程。在 Flink 叢集中,每個 TaskManager 都是一個單獨的 JVM 程序(非 MiniCluster 模式),并且在一個 TaskManager 中可能運作多個子任務,這些子任務都在各自獨立的線程中運作。為了控制一個 TaskManager 中可以運作的任務的數量,引入了 Task Slot 的概念。

看這個圖,假設一個流任務是這樣的

95-280-035-源碼-資源管理-計算資源管理-TaskSlot2.概述3. Task Slot 的基本概念

然後對應的槽位可能是這樣的

繼續閱讀