Flink CDC中postgres cdc在读某表时候会出现某个字段变成小写，然后提示没有为什么？
"Flink CDC中postgres cdc在读某个表时候会出现某个字段变成小写，然后提示没有，但是换成其他表有同样字段却可以，什么原因？
换了个表，同样字段却没转为小写，正常输出，没指定字段，直接去读的，甚至我新建了個表也可以，我現在復現不了我把表刪了重建之後就一直可以。"
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
北京阿里云ACE会长
Flink CDC读Postgres表字段变小写可能的原因:
Postgres表字段定义使用了不区分大小写的数据库,如Postgres本身或其他数据库兼容层。
CDC客户端和Postgres的字符集设置不一致,导致乱码转化。
CDC配置文件属性table.mapping里字段映射定义错误。
表结构或者数据类型发生变更,CDC捕获到旧结构定义。
网络传输或ught课硬错误引起部分字段丢失。
一般来说:
检查Postgres和CDC客户端字符集是否一致
对比表结构与CDC配置是否匹配
断点续传可能导致字段不一致
重启CDC同步表结构
使用其他格式输出检查异常原因
2023-08-10 17:39:11赞同 展开评论 -
意中人就是我呀！
自己建表的问题 你字段是大小写混合，默认是小写的字段。不能复现的问题基本是误操作引起的 可以排查日志看看。此回答整理至钉群“Flink CDC 社区”。
2023-08-09 12:21:07赞同 展开评论
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。