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)