Savepoint 作为实时任务的全局镜像,其在底层使用的代码和Checkpoint的代码是一样的。。怎么记
时间: 2023-06-24 17:06:55 浏览: 88
Savepoint 和 Checkpoint 都是 Flink 中的容错机制,它们的实现代码确实有很多相似之处。在 Flink 中,Checkpoint 是将状态信息异步持久化到分布式文件系统中,以便在发生故障时恢复任务的状态。而 Savepoint 则是将任务的状态信息同步地保存到分布式文件系统中,它可以用于在应用程序运行时手动保存任务的状态,以便在重启应用程序时重新加载该状态。
在底层代码实现上,Savepoint 和 Checkpoint 都使用了 Flink 的状态后端机制,将状态信息保存到分布式文件系统中。它们都需要对状态信息进行序列化和反序列化,以便在保存和恢复状态信息时使用。此外,它们还需要在分布式环境下保证数据的一致性和可靠性,以避免数据丢失或者重复。
因此,可以说 Savepoint 和 Checkpoint 的代码实现非常相似,都是基于 Flink 的状态后端机制实现的。
阅读全文