Flink CDC 快照、结构演进与同步恢复

登记 CDC 3.4.x 与 Flink 1.19/1.20 兼容组合，本试点采用 Flink 1.20、MySQL 8.0.x。记录具体驱动、sink 制品、接入方式、源表负责人、目标表和主键删除语义；选择独立目标与有限数据范围。

在已认证的 MySQL 会话中只读检查一个源与一个已知表，将示例表名替换为批准对象。核对 ROW、FULL、权限、server-id 登记及真实可用日志，保留预算应覆盖快照、停顿和追赶。

SELECT VERSION(), @@GLOBAL.log_bin, @@GLOBAL.binlog_format,
       @@GLOBAL.binlog_row_image, @@GLOBAL.binlog_expire_logs_seconds;
SHOW CREATE TABLE cdc_lab.orders;

在受控配置评审中限定单表、唯一 server-id 范围和初始并行度。以下为不完整 Pipeline 片段，需合并已核验的连接、认证和 sink 配置；不假定 YAML 自动展开环境变量。

source:
  type: mysql
  tables: cdc_lab.orders
  server-id: 5401-5410
  scan.startup.mode: initial
  scan.incremental.snapshot.chunk.size: 2048
pipeline:
  parallelism: 2

按表发现 split 进度指标，关联最慢 chunk、已完成 checkpoint 和后续日志读取。LOW/HIGH 是 binlog 位置，不是事件时间 Watermark；快照结束后等待相应 checkpoint 完成再衔接日志。对一个 Job 只读采集一次，10 秒超时后停止并记录错误。

curl --fail --silent --show-error --max-time 10 \
  "${FLINK_REST_URL}/jobs/${JOB_ID}/checkpoints"

针对单表列出允许和拒绝的结构事件，记录 schema.change.behavior 与 include/exclude，排除规则优先。跟踪 source 事件、MetadataApplier、目标 DDL 状态和后续数据，分别检查类型、空值与默认值。

明确目标是事件追加、主键 upsert 还是事务提交；选定少量业务 ID 比较更新、删除和重复重放。多源 route 合并时加入来源相同主键样本；若目标为 Kafka，再单独核对键、分区和事务可见性。

在专用小表将样本控制为约 100 个主键，覆盖快照期间少量插入、更新、删除和允许的加列。追到约定日志边界后比较主键及最终值，再做一次可撤销的隔离故障恢复，记录恢复 checkpoint、源位置及已完成目标 DDL。

归档版本、配置、Job ID、源位点、checkpoint、目标结构和有限对账结果，说明 binlog 保留余量、未覆盖故障和下一次采样时间。切换入口前独立确认新写入归属和业务补偿路径。