01原始资料清单

资料用于理解
Flink CDC 3.5 · MySQL Source快照与增量捕获、server ID 和源端要求
Flink 1.20 · Join常规 Join 更新、状态保留与 TTL 取舍
Flink 1.20 · Checkpoint状态恢复和 checkpoint 保证的边界
Flink 1.20 · Upsert Kafka按 key 更新、删除与 sink 投递配置
Fluss 0.9 · 湖仓概览分层存储与 Union Read
Iceberg 1.11 · Flink 写入v2 upsert 与主键要求
Iceberg 1.11 · 维护快照过期与孤立文件清理需要显式操作
ClickHouse · ReplacingMergeTree版本选择、后台合并与 FINAL
Flink CDC 3.5：MySQL ↗Flink 1.20：Join ↗Flink 1.20：Checkpoint ↗Flink 1.20：Upsert Kafka ↗Fluss 0.9：湖仓概览 ↗Iceberg 1.11：Flink 写入 ↗Iceberg 1.11：维护 ↗ClickHouse：ReplacingMergeTree ↗

02实现声明的版本基线

这些是仓库声明的版本，不是重新认证的兼容矩阵。部分镜像 tag 代表一个次版本系列，Fluss quickstart 镜像还内置了依赖。记录复现环境时应检查实际镜像 digest 和已安装 JAR。

组件声明基线
Flink / Fluss quickstart 镜像1.20 / 0.9.1-incubating
Flink CDC3.5.0
Flink Kafka SQL 连接器3.4.0-1.20
Paimon S3 插件1.3.1
Iceberg Flink runtime1.11.0
MySQL8.0.40
Kafka broker4.3.1
ClickHouse26.7

03如何使用引用

上游文档解释组件支持的语义；本地 SQL 说明项目实际配置了什么；保存的运行记录说明特定环境中观察到了什么。要得出强结论，应同时使用这三类资料。

链接中的 ClickHouse 文档持续更新，请结合固定的服务端版本理解行为。资料在 2026-11-07 为本次发布核查，上游页面仍可能变化。即使某组件支持更多功能，本项目的已知局限依然适用。

04可继续研究的问题

  • 固定输入与字段级对账如何提高回归验证的价值？
  • 要让删除正确传播到查询服务层，需要哪些改动？
  • 持久化作业恢复、定期湖表维护和明确的时间语义，会怎样改变运行设计？
  • 如何在相同工作负载、正确性检查和资源限制下比较表格式？
回到学习路线 ↗