【发布时间】:2019-04-10 23:05:58
【问题描述】:
我在 RocksDB 中使用增量检查点并将检查点保存到远程目标(在我的情况下为 S3)。 如果有人删除作业管理器服务器(检查点协调器运行的地方)并重新安装它会发生什么? 由于失去了检查点协调员,我也失去了从检查点恢复状态的选项?因为据我所知, 协调器持有检查点的所有引用。
【问题讨论】:
标签: apache-flink flink-streaming
我在 RocksDB 中使用增量检查点并将检查点保存到远程目标(在我的情况下为 S3)。 如果有人删除作业管理器服务器(检查点协调器运行的地方)并重新安装它会发生什么? 由于失去了检查点协调员,我也失去了从检查点恢复状态的选项?因为据我所知, 协调器持有检查点的所有引用。
【问题讨论】:
标签: apache-flink flink-streaming
如果您在启用 high availability 的情况下运行 Flink,则 Flink 会将指向其检查点的指针存储在 ZooKeeper 中。如果 JobManager 失败,Flink 将从 ZooKeeper 恢复所有检查点,并能够从最近完成的检查点恢复作业。
【讨论】: