我正在使用RocksDB的增量检查点并将检查点保存到远程目标(在我的情况下为S3)。如果有人删除了作业管理器服务器(检查点协调员操作的地方)并重新安装它会发生什么?通过失去检查点协调员,我也失去了从检查点恢复状态的选项?因为据我所知,协调员拥有检查站的所有参考资料。
如果你在启用high availability的情况下运行Flink,那么Flink将在ZooKeeper中存储指向其检查点的指针。如果JobManager
失败,Flink将从ZooKeeper恢复所有检查点,并能够从最新完成的检查点恢复作业。