梦洛河

  1. 从 Flink CDC 到 Pekko（五）：海量常驻 CDC 的自建边界——Pekko 控制面与数据运行时的取舍

    系列导读与验证范围 · 1：目标架构 · 2：批转流源码 · 3：真实实验 · 4：恢复协议 · 5：自建与复用 · Flink CDC 深入系列

    2026/10/18 Pekko

  2. 从 Flink CDC 到 Pekko（四）：批转流恢复的证明链——固定范围、封存身份与激活边界

    系列导读与验证范围 · 1：目标架构 · 2：批转流源码 · 3：真实实验 · 4：恢复协议 · 5：自建与复用 · Flink CDC 深入系列

    2026/10/18 Pekko

  3. 从 Flink CDC 到 Pekko（三）：批转流怎样验收——从恢复命题到真实故障证据

    系列导读与验证范围 · 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