使用单个JobManager进行恢复

Question

我正在尝试恢复作业，并在作业管理器关闭而我无法成功重新启动作业时进行状态。

根据我的理解，TaskManager恢复是由JobManager辅助的(这是预期的)，而JobManager恢复是通过Zookeeper完成的。

我想知道是否有一种方法可以在没有zookeeper的情况下恢复作业管理器？

我使用docker进行设置，所有检查点和保存点都保存到映射的卷中。

当所有作业管理器都宕机时，flink是否能够恢复？我可以等待单个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在作业管理器重新启动时被删除，但我不确定如何解决这个问题。

Answer 1

目前，Flink仅支持在使用ZooKeeper的情况下从JobManager故障中恢复。但是，从理论上讲，如果您可以保证只有一个JobManager在运行，那么您也可以让它在没有它的情况下工作。有关详细信息，请参阅此answer。

Answer 2

你可以把你的集群作为一个"Flink Job Cluster“来运行。当容器启动时，这将自动启动您烘焙到docker镜像中的作业。你可以阅读更多的here。