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)

Reply via email to