在Kubernetes中漫游.如何将提交作业步骤添加到作业经理flink docker



我将Flink与K8s一起使用。一切都很好,但当jobmanager启动时,我必须手动提交jar。

我认为我们可以扩展flink图片并添加后期操作来提交作业。所以,工作经理将是一个对一个退缩的工作。我想这是来自https://www.youtube.com/watch?v=w721NI-mtAA

在这种情况下,如果JM关闭,K8将打开新的pod并重新提交作业。

我说得对吗?

有人为弗林克做过这样的码头工人变动吗?

我解决了这个问题。

我扩展了flink Docker,并添加了"flink run"some.jar"step。

它工作完美的

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

相关内容

  • 没有找到相关文章

最新更新