yunhaoww commented on PR #4284:
URL: https://github.com/apache/flink-cdc/pull/4284#issuecomment-4386281180
@sd4324530
你好, 这次的 PR 引入了新的 BUG
--------
Flink CDC 3.6.0 在跑 MySQL → 下游的 pipeline 任务时,如果同时满足:
- 源 MySQL 的 lower_case_table_names != 0(即 1 或 2,macOS / Windows 默认;部分云上
RDS 也这么配)
- 源表 DDL 里有非全小写的列名(大写 / 驼峰均可)
- YAML pipeline 配了 transform 块,且 projection / primary-keys 按 DDL
原大小写引用了这些列
任务在 INITIAL snapshot 阶段就崩,0 行入库,错误堆栈是 Column 'XXX' not found in any
table,且故障 CreateTableEvent 的 schema 是空列 columns={} 但 primaryKeys
是有值的。任务进入崩溃循环,自动重启也不会自愈。
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]