Kubernetes 中的 Flink。如何将提交作业步骤添加到 jobmanager flink docker?

Flink in Kubernetes. How to add submit job step to jobmanager flink docker?

我使用 Flink 和 K8s。一切正常,但我必须在 jobmanager 启动时手动提交 jar。

我认为我们可以扩展 flink 图像并添加 post 操作来提交作业。 所以 jobmanager 将是一对一的 flink 工作。 我认为这是 https://www.youtube.com/watch?v=w721NI-mtAA

的想法

在这种情况下,如果 JM 宕机,K8s 将启动新的 pod 并重新提交作业。

我说得对吗?

有人对 flink 有这样的 docker 改动吗?

我解决了这个问题。

我扩展了 flink Docker 并添加了 "Flink run "some.jar"" 步骤。

效果完美

https://github.com/Aleksandr-Filichkin/flink-k8s