梦洛河

  1. 从 Flink CDC 到 Pekko（五）：自建批转流之后——Pekko 与 Flink CDC 的能力、成本和边界

    系列导读与验证范围 · 1：目标架构 · 2：批转流源码 · 3：真实实验 · 4：恢复协议 · 5：框架比较 · Flink CDC 深入系列 · 初始化实验 · 启动恢复反例

    2026/10/18 Pekko

  2. 从 Flink CDC 到 Pekko（四）：窗口与进度怎样恢复——封存、T/J/D、确认前缀与取消

    系列导读与验证范围 · 1：目标架构 · 2：批转流源码 · 3：真实实验 · 4：恢复协议 · 5：框架比较 · Flink CDC 深入系列 · 初始化实验 · 启动恢复反例

    2026/10/18 Pekko

  3. 从 Flink CDC 到 Pekko（三）：批转流怎样验收——真实 MySQL、Journal、Sink 与启动反例

    系列导读与验证范围 · 1：目标架构 · 2：批转流源码 · 3：真实实验 · 4：恢复协议 · 5：框架比较 · Flink CDC 深入系列 · 初始化实验 · 启动恢复反例

    2026/10/18 Pekko

  4. 从 Flink CDC 到 Pekko（二）：从分页快照到持续同步——沿源码走通 LOW/HIGH 与 B→F

    系列导读与验证范围 · 1：目标架构 · 2：批转流源码 · 3：真实实验 · 4：恢复协议 · 5：框架比较 · Flink CDC 深入系列 · 初始化实验 · 启动恢复反例

    2026/10/18 Pekko

  5. 从 Flink CDC 到 Pekko（一）：70 万表的常驻 CDC——共享 Reader、表级 Actor 与有界执行

    系列导读与验证范围 · 1：目标架构 · 2：批转流源码 · 3：真实实验 · 4：恢复协议 · 5：框架比较 · 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

Search

    Categories Cloud

    Linux Xiaomi ShellClash SQL Streamparek Zio streamparek doris 占比 组内占比 SeaTunnel Spark Kubernetes 数据集成 Flink OpenLineage ZIO Pekko

    My Popular Repositories

    pekko-reference

    pekko-playground-reference

    4 0

    xxt-cdc

    cdc

    1 0

    Xuxiaotuan.github.io

    blog

    1 0

    turbo-for90night

    Inspired by https://github.com/MichaelCade/90DaysOfDevOps

    1 1

    prism-zio

    Rewrite prism, A highly concurrent system using ZIO

    1 0