Skip to content

Commit a0699ac

Browse files
[FLINK-38244][hotfix] Fix case-insensitive error when adding column After an existed column. (apache#4100)
1 parent 10e84ca commit a0699ac

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

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)