我正在尝试恢复我的工作并说明当我的JobManager失败并且我无法成功重新开始工作时。
根据我的理解,JobManager恢复由JobManager辅助(这可以按预期工作),并通过Zookeeper完成JobManager恢复。
我想知道是否有办法找回JobManager?
我正在使用docker进行设置,所有检查点和保存点都会持久保存到映射的卷。
当所有jobmanager都倒下时,flink能够恢复吗?我可以等待单个JobManager重新启动。
当我重新启动jobmanager时,我得到以下异常: org.apache.flink.runtime.rest.NotFoundException: Job 446f4392adc32f8e7ba405a474b49e32 not found
我在我的网站上设置了以下内容 flink-conf.yaml
state.backend: filesystem
state.checkpoints.dir: file:///opt/flink/checkpoints
state.savepoints.dir: file:///opt/flink/savepoints
我认为我的问题可能是当作业管理器重新启动时JAR被删除但我不知道如何解决这个问题。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
目前,JobManager如果您使用ZooKeeper ,Flink仅支持从故障中恢复。但是,理论上如果你可以保证只有JobManager一次运行,你也可以在没有它的情况下使它工作。