Flink源码阅读：Checkpoint机制（下）

2026-01-01 分类：技术专栏 阅读(6) 评论(0)

前面我们了解到在
StreamOperatorStateHandler.snapshotState 方法中会创建四个 Future，用来支持不同类型的状态写入。