如何用代码提交打包好的job到flink集群？

Question

如何用Java代码将打包好的job提交到flink on yarn session集群上呢？
如果是per job模式和application模式呢？
flink版本1.13.2
jdk版本1.8

Answer 1

Michael_PK 2022-03-18 12:27:33

所有的提交方式的使用，官网上都有详细的描述。

这是最新版本的提交方式：https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/resource-providers/yarn/

你到官网上找到你的flink的版本对应的on yarn的文档就可以

• 提问者 cy666 #1

  这篇文档我已经看过了，但是官网描述的都是通过命令行方式提交，请问如何通过Java代码提交呢?有没有什么文档可以参考呢？

• Michael_PK 回复 提问者 cy666 #2

  作业都是用命令方式提交的。

• 提问者 cy666 回复 Michael_PK #3

  生产上也是通过命令行方式提交吗？还是说通过flink本身的web ui进行提交

点开查看后面3条评论