Flink：在Flink集羣上執行Jar文件

我在2個不同的物理節點上使用9個任務管理器的flink集羣。當我將這個罐子提交給Flink的Jobmanager（Master）時，罐子發生了什麼。我的意思是，罐子是否分配給所有工作節點，或者該功能的某些部分是否重新分配給所有工作節點？Flink：在Flink集羣上執行Jar文件

我在問這是因爲，當我試圖運行我的應用程序時，它在本地運行成功，但在集羣上運行時在FlatMapFunction上出現序列化錯誤。

2017-02-23 kadsank

-1

作業管理器進程應用程序代碼，將其分解爲任務和子任務，並將它們發送到任務管理器中的一個或多個（取決於任務並行）執行槽。從弗林克documentation：

每個工人（任務管理）是JVM的過程，和在單獨的線程可以執行一個或更多子任務。要控制多少任務的工作人員接受，工人已經所謂的任務插槽（至少一個）。]

Check this diagram

2018-02-27 20:59:37 Genady

回答