我在rocksdb中使用增量检查点,并将检查点保存到远程目的地(在我的例子中是s3)。如果有人删除作业管理器服务器(检查点协调器在其中操作)并重新安装它,会发生什么情况?失去了检查点协调器,我也失去了从检查点恢复状态的选项?因为据我所知,协调人保存了所有检查点的参考资料。
cqoc49vn1#
如果您在启用高可用性的情况下运行flink,那么flink将在zookeeper中存储指向其检查点的指针。如果发生 JobManager 如果失败,flink将从zookeeper恢复所有检查点,并能够从最新完成的检查点恢复作业。
JobManager
1条答案
按热度按时间cqoc49vn1#
如果您在启用高可用性的情况下运行flink,那么flink将在zookeeper中存储指向其检查点的指针。如果发生
JobManager
如果失败,flink将从zookeeper恢复所有检查点,并能够从最新完成的检查点恢复作业。