flink 任务对接k8s的第三方jar包管理问题

[天道酬勤 <12...@qq.com.INVALID>]

我的flink是通过kubernetes session 模式部署 ，在提交任务的时候希望可以动态指定第三方jar包来运行自己的任务，目前在官网中未找到可用的配置项。
希望大家能给我一些建议!

Re: flink 任务对接k8s的第三方jar包管理问题

[zns <zh...@foxmail.com>]

https://blog.csdn.net/ifenggege/article/details/113731793 <https://blog.csdn.net/ifenggege/article/details/113731793>
这个yarn的供参考

> 2022年4月25日 16:50，天道酬勤 <12...@qq.com.INVALID> 写道：
> 
> 我的flink是通过kubernetes session 模式部署 ，在提交任务的时候希望可以动态指定第三方jar包来运行自己的任务，目前在官网中未找到可用的配置项。
> 希望大家能给我一些建议!

Re: flink 任务对接k8s的第三方jar包管理问题

[Yang Wang <da...@gmail.com>]

* 使用flink run命令来提交任务到running的Session集群的话，只能是本地的jar

* 也可以使用rest接口来提交，先上传到JobManager端[1]，然后运行上传的jar[2]

* 最后可以尝试一下flink-kubernetes-operator项目，目前Session job是支持远程jar的[3]，项目还在不断完善

[1].
https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/ops/rest_api/#jars-upload
[2].
https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/ops/rest_api/#jars-jarid-run
[3].
https://github.com/apache/flink-kubernetes-operator/blob/main/e2e-tests/data/sessionjob-cr.yaml

Best,
Yang

天道酬勤 <12...@qq.com.invalid> 于2022年4月25日周一 16:51写道：

> 我的flink是通过kubernetes session 模式部署
> ，在提交任务的时候希望可以动态指定第三方jar包来运行自己的任务，目前在官网中未找到可用的配置项。
> 希望大家能给我一些建议!