* 使用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

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

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

回复