Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-36804

When the same number of characters in Chinese table names exists, initiate error reporting.

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 3.0.0
    • None
    • Flink CDC
    • None

    Description

      flink1.18

      flink-cdc 3.2.0

      use  mysql cdc connector.

      Caused by: org.apache.flink.cdc.connectors.shaded.org.apache.kafka.connect.errors.ConnectException: The Kafka Connect schema name 'mysql_binlog_source.test2.用户表.Value' is not a valid Avro schema name and its replacement 'mysql_binlog_source.test2.___.Value' conflicts with another different schema 'mysql_binlog_source.test2.姓名表.Value'

      mysql DDL:

      //代码占位符
      create table 用户表
      (
      主键 INT(10) not null
      primary key,
      姓名 VARCHAR(2444) null
      );
      create table 姓名表
      (
      主键 INT(10) not null
      primary key,
      姓名 VARCHAR(2444) null
      ); 

      Attachments

        Activity

          People

            Unassigned Unassigned
            huzekang hzk
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: