我将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