开发者社区 问答 正文

使用单个JobManager进行恢复

我正在尝试恢复我的工作并说明当我的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被删除但我不知道如何解决这个问题。

展开
收起
flink小助手 2018-12-10 13:22:29 3048 分享 版权
1 条回答
写回答
取消 提交回答
  • flink小助手会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关flink的问题及回答。

    目前,JobManager如果您使用ZooKeeper ,Flink仅支持从故障中恢复。但是,理论上如果你可以保证只有JobManager一次运行,你也可以在没有它的情况下使它工作。

    2019-07-17 23:19:12
    赞同 展开评论