Apache Flink - 重新启动后在同一 JobManager 上重新启动作业

Question

在 Apache Flink 上没有 HA 设置的情况下是否可以执行以下场景？

• 开始工作
• 重新启动作业管理器
• 作业管理器根据检查点重新启动之前启动的作业

我试图设置各种属性，但每次重新启动JM后，基本上什么也没有发生。

那么可以在没有HA设置的情况下完成吗？我现在使用的是1.19版本。 从我发现的答案来看，似乎不是，我们必须让 HA 集群进行领导者选举，然后新的领导者应该重新启动工作。

想确认这一点。

Answer 1

如果您有保存点或保留的检查点，我相信您应该能够重新启动JM，然后从保存的状态重新启动作业。