Flink的Job啓動TaskManager端（源碼分析）

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

>>阅读原文<<