flink on yarn 的application模式怎么提交多个job组成应用程序呢？
1.flink on yarn 的application模式怎么提交多个job组成应用程序呢？在官网和论坛的文章中这里没有详细展开。
与per-job 模式相比，Application 模式允许提交由多个Job组成的应用程序。Job执行的顺序不受部署模式的影响，但受启动Job的调用的影响。使用阻塞的 execute()方法，将是一个顺序执行的效果，结果就是"下一个"Job的执行被推迟到“该”Job完成为止。相反，一旦提交当前作业，非阻塞executeAsync()方法将立即继续提交“下一个”Job。
怎么做到呢？
2.而且提交job时，没有指定运行main方法的类，那么在jobmanager是如何找到对应的执行main呢？ 官网比如这个指令： ./bin/flink run-application -t yarn-application \ -Djobmanager.memory.process.size=2048m \ -Dtaskmanager.memory.process.size=4096m \ ./MyApplication.jar
*来自志愿者整理的flink邮件归档
写回答
-
-
目前Flink是允许在一个user jar的main里面，运行多次execute的，包括executeAsyc。 每执行一次execute，就是提交了一个任务。所以你是可以这样来实现一个Application里面 运行多个job。但这里需要注意的是，目前只有非HA的Application模式可以支持多job HA模式还不行，具体原因主要是恢复起来会很麻烦，还没有实现。
-
Flink会检查用户提交的user jar，然后从其中提取出来。具体可以看一下PackagedProgram#loadMainClass 的实现。*来自志愿者整理的flink
2021-12-07 20:24:24赞同 展开评论 打赏 -
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
