我用flink和k8。一切正常，但当jobmanager启动时，我必须手动提交jar。
我认为我们可以扩大Flink形象和添加后行动提交工作。所以jobmanager将是一对一的flink工作。我想这是我的主意https://www.youtube.com/watch?v=w721ni-mtaa
在这种情况下，如果jm停机，k8s将启动新pod并重新提交作业。
我说得对吗？
有人给Flink换过这样的 Docker 吗？
我用flink和k8。一切正常，但当jobmanager启动时，我必须手动提交jar。
我认为我们可以扩大Flink形象和添加后行动提交工作。所以jobmanager将是一对一的flink工作。我想这是我的主意https://www.youtube.com/watch?v=w721ni-mtaa
在这种情况下，如果jm停机，k8s将启动新pod并重新提交作业。
我说得对吗？
有人给Flink换过这样的 Docker 吗？
1条答案
按热度按时间qmelpv7a1#
我解决了这个问题。
我扩展了flink docker并添加了“flink run”some.jar“”步骤。
它工作得很好
https://github.com/aleksandr-filichkin/flink-k8s