tongchenkeji
发表于：0次点击

请问大神们，Flink CDC这是什么原因引起的。创建表的字段并没有“file”这字段？[阿里云实时计算 Flink版]

请问大神们，Flink CDC这是什么原因引起的。创建表的字段并没有“file”这字段？org.apache.kafka.connect.errors.dataexception: file is not a valid field name在2.3上没这问题，现换在2.4，2.4做个简单的测试，发现数据都无法查询，又没报错。

「点点赞赏，手留余香」

    还没有人赞赏，快来当第一个赞赏的人吧！
实时计算Flink版# 云消息队列 Kafka 版375# 实时计算 Flink版3179# 流计算2236
=====这是一个广告位，招租中，联系qq 78315851====
实时计算Flink版
Flink CDC中改了之后重新运行报这个错，是不是jackson包版本冲突了？项目中声明的是2.1[阿里云实时计算 Flink版]
实时计算Flink版
有没有兄弟遇到过Flink CDC中修改数据 但是cdc采集不到的问题？sql方式没试过[阿里云实时计算 Flink版]
2 条回复 A 作者 M 管理员

  1. org.apache.kafka.connect.errors.DataException: file is not a valid field name 错误通常是由于字段名不合法导致的。在 Flink CDC 中，需要在 CDC 配置中指定需要同步的表和字段。

    根据您提供的信息，如果创建表时并没有包含名为 “file” 的字段，那么可能是因为 CDC 配置中错误地指定了该字段。请确保正确指定需要同步的字段，并将其包含在 CDC 配置的 fields 属性中。

    举例来说，您可以在 CDC 配置中使用以下方式指定需要同步的字段：

    source:  type: mysql-binlog  hostname: localhost  port: 3306  username: root  password: 123456  database-name: test  table-name: my_table  startup-mode: earliest  fields:    - name: id      type: INT    - name: name      type: VARCHAR    - name: age      type: INT

    在上述示例配置中，通过 fields 属性指定了需要同步的字段，包括 id、name、和 age。请确保在 CDC 配置中正确指定需要同步的字段列表，避免出现字段名不合法或未指定的情况。

    需要注意的是，如果在 CDC 配置中未正确指定需要同步的字段，可能会导致同步失败或者同步的数据不完整。因此，在使用 Flink CDC 时，需要确保 CDC 配置正确，并指定需要同步的表和字段

    已喜欢 已反对

  2. 段。
    在 Flink CDC 中，需要在 CDC 配置中指定需要同步的表和字段，例如：
    yaml
    Copy
    source:
    type: mysql-binlog
    hostname: localhost
    port: 3306
    username: root
    password: 123456
    database-name: test
    table-name: my_table
    startup-mode: earliest
    fields:

    - name: id  type: INT- name: name  type: VARCHAR- name: age  type: INT

    在以上配置中，通过 fields 属性指定了需要同步的字段，包括 id、name 和 age。如果在创建表的时候未包括 file 字段，可能是因为未将其包含在 CDC 配置的 fields 属性中。
    需要注意的是，如果在 CDC 配置中未正确指定需要同步的字段，可能会导致同步失败或者同步的数据不完整。因此，在使用 Flink CDC 时，需要确保 CDC 配置正确，并指定需要同步的表和字段

    已喜欢 已反对

  3. 是不是写错了，或者是个关键字，此回答整理自钉群“Flink CDC 社区”

    已喜欢 已反对