Apache Flink 状态管理深度解析:从 Barrier 到端到端 Exactly-Once

以一个双输入聚合任务贯穿 Flink 状态管理论文:逐记录推演 Barrier Alignment、异步增量快照、故障恢复、事务 Sink、扩缩容,并区分 2017 年论文与 Flink 2.3 的实现边界。

2026 年 7 月 16 日 · 11 min · Niu Zhiwei

我的个人博客第一版上线

第一版博客上线:后续会重点沉淀 Java、Go、大数据与 AI 工程实践。

2026 年 7 月 7 日 · 1 min · Niu Zhiwei