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

来源:1-1 课前须知,这里有你需要了解得一切

cy666

2022-03-16

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

写回答

1回答

Michael_PK

2022-03-18

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

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

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

0
6
Michael_PK
回复
cy666
那就做个页面就可以了,封装成一个shell脚本,然后通过调度启动就行了
2022-03-22
共6条回复

Flink+ClickHouse 玩转企业级实时大数据开发

已经在做大数据,Flink助力轻松提薪;尚未入行,让你弯道超车

1000 学习 · 225 问题

查看课程