Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
3.0.0
-
None
-
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 );