Skip to content

Commit 5f02a54

Browse files
loserwang1024Mrart
authored andcommitted
[FLINK-38244][hotfix] Fix case-insensitive error when adding column After an existed column. (#4100)
1 parent c56aa50 commit 5f02a54

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomAlterTableParserListener.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -226,6 +226,9 @@ public void exitAlterByAddColumn(MySqlParser.AlterByAddColumnContext ctx) {
226226
null))));
227227
} else if (ctx.AFTER() != null) {
228228
String afterColumn = parser.parseName(ctx.uid(1));
229+
if (isTableIdCaseInsensitive) {
230+
afterColumn = afterColumn.toLowerCase(Locale.ROOT);
231+
}
229232
changes.add(
230233
new AddColumnEvent(
231234
currentTable,

0 commit comments

Comments
 (0)