1. 从 Flink CDC 到 Pekko(五):Pekko CDC 和 Flink CDC——70 万表常驻场景下,谁解决了什么问题

    系列导读 · 第一篇:常驻 CDC · 第二篇:恢复协议 · 第三篇:真实故障 · 第四篇:批转流 · 第五篇:Pekko 与 Flink · Flink CDC 深入系列

    2026/10/18 Pekko

  2. 从 Flink CDC 到 Pekko(四):从批到流——LOW/HIGH、B/F/K 为什么必须是一个状态机

    系列导读 · 第一篇:常驻 CDC · 第二篇:恢复协议 · 第三篇:真实故障 · 第四篇:批转流 · 第五篇:Pekko 与 Flink · Flink CDC 深入系列

    2026/10/18 Pekko

  3. 从 Flink CDC 到 Pekko(三):一条 MySQL UPDATE 什么时候才算被 CDC 接受?

    系列导读 · 第一篇:常驻 CDC · 第二篇:恢复协议 · 第三篇:真实故障 · 第四篇:批转流 · 第五篇:Pekko 与 Flink · Flink CDC 深入系列

    2026/10/18 Pekko

  4. 从 Flink CDC 到 Pekko(二):一条 ACK 链如何成为可恢复的 T/J/D 协议

    系列导读 · 第一篇:常驻 CDC · 第二篇:恢复协议 · 第三篇:真实故障 · 第四篇:批转流 · 第五篇:Pekko 与 Flink · Flink CDC 深入系列

    2026/10/18 Pekko

  5. 从 Flink CDC 到 Pekko(一):70 万张表常驻 CDC——共享 Reader、表级执行单元和有界资源

    系列导读 · 第一篇:常驻 CDC · 第二篇:恢复协议 · 第三篇:真实故障 · 第四篇:批转流 · 第五篇:Pekko 与 Flink · Flink CDC 深入系列

    2026/10/18 Pekko

  6. Flink CDC 深入解析(五):从 MySQL 到 Paimon 的提交与恢复

    系列导读与验证材料 · 一:一致性边界 · 二:增量快照 · 三·上:Source 状态机 · 三·下:故障恢复 · 四:Schema 演进 · 五:Paimon 提交 · Pekko CDC:执行模型与恢复协议

    2026/10/18 Flink

  7. Flink CDC 深入解析(四):Schema 演进的捕获、传播与恢复

    系列导读与验证材料 · 一:一致性边界 · 二:增量快照 · 三·上:Source 状态机 · 三·下:故障恢复 · 四:Schema 演进 · 五:Paimon 提交 · Pekko CDC:执行模型与恢复协议

    2026/10/18 Flink

  8. Flink CDC 深入解析(三·下):Checkpoint 恢复与故障窗口

    系列导读与验证材料 · 一:一致性边界 · 二:增量快照 · 三·上:Source 状态机 · 三·下:故障恢复 · 四:Schema 演进 · 五:Paimon 提交 · Pekko CDC:执行模型与恢复协议

    2026/10/18 Flink

  9. Flink CDC 深入解析(三·上):Source 状态机与快照切换

    系列导读与验证材料 · 一:一致性边界 · 二:增量快照 · 三·上:Source 状态机 · 三·下:故障恢复 · 四:Schema 演进 · 五:Paimon 提交 · Pekko CDC:执行模型与恢复协议

    2026/10/18 Flink

  10. Flink CDC 深入解析(二):增量快照的水位、回填与多 Chunk 衔接

    系列导读与验证材料 · 一:一致性边界 · 二:增量快照 · 三·上:Source 状态机 · 三·下:故障恢复 · 四:Schema 演进 · 五:Paimon 提交 · Pekko CDC:执行模型与恢复协议

    2026/10/18 Flink