7.2.2.1 表结构变更捕获

文档摘要

7.2.2.1 表结构变更捕获 7.2.2.1 表结构变更捕获：当在凌晨三点悄然执行，而你的 CDC 管道已静默丢弃了 47 小时的数据流凌晨 3:17，告警钉钉弹出第 12 条消息：“Flink job ‘orders-cdc-processor’ 连续 6 小时未产出有效 records”。你揉着太阳穴点开 Metrics 页面——Source 并未背压，Kafka lag 持平，但下游 Parquet 文件的 schema 版本号却卡死在，而上游 MySQL 的表已在 19 小时前由 DBA 执行了。