我正在尝试了解检查点恢复的过程,到目前为止,我只找到了有关增量检查点机制如何工作的信息。通常,当您在其他地方谈论备份过程时,您谈论的是第一个完整操作和之后的增量操作,它表示完整和增量之间的增量。但是在这里,当我们谈论增量检查点时,我们不会对状态进行完整的快照,而是立即从增量机制开始。所以我试图理解的是,当我们使用保留并且我们只剩下几个增量检查点时,它是如何工作的,那么如果增量检查点只表示从一个检查点到另一个检查点的更改,我们如何填充所有状态数据。
为了使增量检查点正常工作,Flink 为每个检查点存储完全恢复检查点状态所需的增量(也称为共享状态对象(。增量/共享状态对象实际上是两个检查点之间的差异。根据状态访问和压缩逻辑,在最极端的情况下,这只能是您采用的最新增量或增量的完整历史记录。
由于 Flink 会跟踪检查点仍在引用哪些增量,因此它也知道何时不再需要增量(不再存在对它的引用(。如果发生这种情况,则相应的增量将被删除。