开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC中postgres cdc在读某表时候会出现某个字段变成小写,然后提示没有为什么?

"Flink CDC中postgres cdc在读某个表时候会出现某个字段变成小写,然后提示没有,但是换成其他表有同样字段却可以,什么原因?
16e2d29ec432cdcaf11f8714a101e17d.png
换了个表,同样字段却没转为小写,正常输出,没指定字段,直接去读的,甚至我新建了個表也可以,我現在復現不了我把表刪了重建之後就一直可以。"

展开
收起
十一0204 2023-08-09 10:19:25 123 0
2 条回答
写回答
取消 提交回答
  • 北京阿里云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 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载