梦洛河

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

    源码与本轮材料固定到 f6313c0。历史实验继续使用各自冻结版本。

    2026/10/18 Pekko

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

    源码与本轮材料固定到 f6313c0。历史实验继续使用各自冻结版本。

    2026/10/18 Pekko

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

    源码与本轮材料固定到 f6313c0。历史实验继续使用各自冻结版本。

    2026/10/18 Pekko

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

    源码与本轮材料固定到 f6313c0。历史实验继续使用各自冻结版本。

    2026/10/18 Pekko

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

    源码与本轮材料固定到 f6313c0。历史实验继续使用各自冻结版本。

    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

    5 0

    Xuxiaotuan.github.io

    blog

    2 0

    zio-flink-operator-lab

    1 0

    xxt-cdc

    cdc

    1 0

    turbo-for90night

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

    1 1