Flink的TaskManager启动(源码分析)

通过启动脚本已经找到了TaskManager 的启动类org.apache.flink.runtime.taskexecutor.TaskManagerRunner 来看一下它的main方法中 最后被start了起来 start其实是将taskManager 端的RPC服务起起来了 看一下TaskManagerRunner的构造方法中 调用了这个startTaskManager()方法，在这个方法

>>阅读原文<<