如图,
使用指令 flink run -m yarn-cluster ........提交多个任务到yarn集群上 集群所给资源充足.
第一个任务为流任务, 读取kafka数据并输出到数据库, 先提交第一个任务, 等到任务进入running状态再提交下一个任务
第二个任务为批处理, 读文本处理后输出到kafka, 提交第二个任务使用的指令不变, 仍然是flink run -m yarn-cluster...
理论情况下, 应该是另起一个任务, 与第一个任务互不影响, 然而在yarn创建了新的application后(图中的007) , 任务仍然进入了006application中执行. 导致批处理结束后, 自动关闭AM. 使第一个流任务无法执行下去
而007这个AM仍然在running状态.(最终手动kill掉)
在网上搜索不到类似场景, 希望各位老师们能够帮我解决这个问题.