Flink的TaskManager啓動(源碼分析)

通過啓動腳本已經找到了TaskManager 的啓動類org.apache.flink.runtime.taskexecutor.TaskManagerRunner 來看一下它的main方法中 最後被start了起來 start其實是將taskManager 端的RPC服務起起來了 看一下TaskManagerRunner的構造方法中 調用了這個startTaskManager()方法，在這個方法

>>阅读原文<<