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