Flink CDC Issue Import created FLINK-34789: ----------------------------------------------
Summary: [Bug] DBZ-5589 Mysql connector can't handle the case sensitive of rename/change column statement Key: FLINK-34789 URL: https://issues.apache.org/jira/browse/FLINK-34789 Project: Flink Issue Type: Bug Components: Flink CDC Reporter: Flink CDC Issue Import ### Search before asking - [X] I searched in the [issues|https://github.com/ververica/flink-cdc-connectors/issues] and found nothing similar. ### Flink version ALL ### Flink CDC version ALL ### Database and its version MySQL, ALL version ### Minimal reproduce step 1. create a table and write some data; 2. listen it‘s binlog Source:mysql , Sink:print; 3. alter a column case and update data. ### What did you expect to see? when i modify a clumn case, the filed name in the binlog record should be changed. ### What did you see instead? I changed a field name to lowercase, but its field name in binlog is still uppercase. ### Anything else? its a bug of debezium. source code in debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/antlr/listener/AlterTableParserListener.java:AlterTableParserListener.java Debezium 2.0.0 fix it by modify line 187 and line 349. Use equals insdead of equalsIgnoreCase method. ![alter_clumn_test|https://github.com/ververica/flink-cdc-connectors/assets/75104806/9e8e4e8f-cfac-4dfe-8400-e757eb49a951] ### Are you willing to submit a PR? - [x] I'm willing to submit a PR! ---------------- Imported from GitHub ---------------- Url: https://github.com/apache/flink-cdc/issues/2144 Created by: [dua01|https://github.com/dua01] Labels: bug, Created at: Thu May 18 11:14:19 CST 2023 State: open -- This message was sent by Atlassian Jira (v8.20.10#820010)