1. ZIO 与 Flink 控制面(三):用一次 Savepoint 恢复检验多副本设计

    一个 Flink 控制面有两个副本,用户提交恢复请求后刷新页面,第二次请求落到了另一个副本。它能否查到同一次操作?如果第一个副本恰好在提交后退出,另一个副本应该继续观察,还是重新提交?最后,凭什么说作业确实从指定 Savepoint 恢复了?

    2026/10/14 ZIO Flink

  2. ZIO 与 Flink 控制面(二):沿一次请求读懂依赖、错误与资源管理

    上一篇把控制面的目标拆成了四件事:接受意图、执行副作用、观察结果、验证证据。本篇沿一次 HTTP 请求读源码,看看 ZIO 在这些边界上具体做了什么。

    2026/10/14 ZIO Flink

  3. ZIO 与 Flink 控制面(一):从 StreamPark 的旧笔记重新出发

    2023 年,我在看 StreamPark 的 Flink Kubernetes 模块时,写过两篇笔记:《Flink Kubernetes Module 为什么使用 ZIO?》和《内嵌 HTTP 文件服务》。当时主要在理解一件事:为什么部署 Flink、监听 Kubernetes 事件、启动文件服务,都可以写成一段 ZIO 程序?

    2026/10/14 ZIO Flink

  4. Flink 字段血缘系列(三):从开源分析到 Flink 原生解析

    Flink 字段血缘系列(三):从开源分析到 Flink 原生解析

    2026/09/25 Flink OpenLineage

  5. Flink 字段血缘系列(二):从 RelNode 到可传输关系

    Flink 字段血缘系列(二):从 RelNode 到可传输关系

    2026/09/25 Flink OpenLineage

  6. Flink 字段血缘系列(一):从表级血缘到字段血缘

    Flink 字段血缘系列(一):从表级血缘到字段血缘

    2026/09/25 Flink OpenLineage

  7. SeaTunnel Spark 适配器源码深度解析(六):扩展开发指南

    SeaTunnel Spark 适配器源码深度解析(六):扩展开发指南

    2025/07/21 SeaTunnel Spark 数据集成

  8. SeaTunnel Spark 适配器源码深度解析(五):性能优化关键点

    SeaTunnel Spark 适配器源码深度解析(五):性能优化关键点

    2025/07/21 SeaTunnel Spark 数据集成

  9. SeaTunnel Spark 适配器源码深度解析(四):状态管理与容错

    SeaTunnel Spark 适配器源码深度解析(四):状态管理与容错

    2025/07/21 SeaTunnel Spark 数据集成

  10. SeaTunnel Spark 适配器源码深度解析(三):执行引擎黑盒

    SeaTunnel Spark 适配器源码深度解析(三):执行引擎黑盒

    2025/07/21 SeaTunnel Spark 数据集成