flink savepoint和checkpoint
时间: 2023-04-18 18:00:24 浏览: 145
flink状态管理示例代码大全完整中文注释
Flink的savepoint和checkpoint都是用于容错的机制。
Checkpoint是在Flink运行过程中周期性地保存应用程序的状态,以便在发生故障时可以恢复应用程序的状态。Checkpoint可以在本地磁盘或远程存储中保存,以确保数据的安全性和可靠性。
Savepoint是一种手动触发的checkpoint,它可以在应用程序运行时手动创建。Savepoint可以用于在应用程序升级或更改时,保存当前应用程序的状态,以便在升级或更改后可以恢复应用程序的状态。
总之,Flink的savepoint和checkpoint都是非常重要的容错机制,可以确保应用程序的可靠性和稳定性。
阅读全文