Flink的Job启动TaskManager端（源码分析）

先来看一下，TaskManager端用来接收JobManager发送过来的TDD对象的RPC接口 在TaskExecutor.java中 这个方法用于接收了一个TaskDeploymentDescriptor对象用于启动任务（上一篇知道这里executionGraph的每一个并行度都会调用deploy方法生成一个TDD） 来看一下具体接收到以后做了什么 创建了一个Task并且将其内部的一个线程启动

>>阅读原文<<