You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "yunhaoww (via GitHub)" <gi...@apache.org> on 2026/05/06 08:25:49 UTC
Re: [PR] [FLINK-38244][hotfix] Fix the full snapshot phase, the field case is adjusted based on isTableIdCaseInsensitive [flink-cdc]
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: issues-unsubscribe@flink.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org