Flink的Job啓動TaskManager端(源碼分析)

先來看一下,TaskManager端用來接收JobManager發送過來的TDD對象的RPC接口 在TaskExecutor.java中 這個方法用於接收了一個TaskDeploymentDescriptor對象用於啓動任務(上一篇知道這裏executionGraph的每一個並行度都會調用deploy方法生成一個TDD) 來看一下具體接收到以後做了什麼 創建了一個Task並且將其內部的一個線程啓動
相關文章
相關標籤/搜索