Flink on Yarn模式下的TaskManager數量

Flink on YARN支持兩種模式。壹種是提前在YARN上啟動壹個長時間運行的Flink集群，所有Flink作業都將提交到這個集群，享受Flink集群資源。另壹種模式是僅在YARN上運行單個Flink作業，YARN負責分配每個作業所需的資源。本文總結了第二種模式下的並發配置和TaskManager上拉。

並行可以通過多種方式進行配置，例如配置全局默認參數、配置客戶端參數、配置運算符參數等等。由於不是本文的重點，我們可以參考Flink官網。

此參數用於配置TaskManager有多少個並發插槽。有兩種配置:

註意:在按作業模式下提交作業時，與會話模式不同，可以指定可以調出多少個任務管理器。任務管理器的數量是根據提交作業時的並發性動態計算的。

首先，根據運算符設置的最大並發量進行計算。例如，如果作業中操作員的最大並發數是10，那麽Parallelism/numberOfTaskSlots就是應用於YARN的TaskManager的數量。

例如，對於以下操作，並行度為10，任務槽數為1，任務管理器為10。

如果numberOfTaskSlots為3，則TaskManager為4。