Hi,
我在使用flink的过程中，有些疑问请教下各位：
1.flink分为jobmanger和taskmanager，我怎么区分哪些代码是运行在jobmanager，哪些在taskmanager？
2.假设我jarA中使用AbstractYarnClusterDescriptor.deployJobCluster()替代flink
run命令（想直接通过jar包启动方式直接提交flink任务上yarn），部署jarB到yarn上，jarB中mainClass中使用StreamExecutionEnvironment.execute去执行流任务，通过java
-cp jarA的方式来启动，首先能确定的一点是jarA运行在服务器本地端，jarB中mainClass是否已经运行在yarn上了？还是运行在服务器端？
服务器端指的是java -cp执行的服务器
我这边本身从日志打印和远程debug（java -cp中加remote debug参数和flink-conf.yaml中加入remote
debug配置）来看，jarB中的mainClass还未运行在yarn上，这个是什么原因？
[email protected]
