[
https://issues.apache.org/jira/browse/FLINK-40087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18094231#comment-18094231
]
Xin Gong commented on FLINK-40087:
----------------------------------
I'm willing to submit a PR.
> MySqlDefaultValueConverter fails to parse charset-introducer default values
> wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0
> "`)
> ------------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-40087
> URL: https://issues.apache.org/jira/browse/FLINK-40087
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.1.0, cdc-3.2.0, cdc-3.1.1, cdc-3.3.0, cdc-3.2.1,
> cdc-3.4.0, cdc-3.3.1, cdc-3.5.0, cdc-3.6.1
> Reporter: Xin Gong
> Priority: Major
> Fix For: cdc-3.6.0
>
>
> # Create a Flink CDC MySQL source that syncs a MySQL database flink_test.
> # Run the following DDL on the upstream MySQL:
> ALTER TABLE flink_test.family2
> ADD COLUMN directive6 TINYINT(4) DEFAULT _UTF8MB4" 0 " COMMENT
> 'directive business';
>
> java.lang.NumberFormatException: For input string: "_UTF8MB4\" 0 \""
> at
> java.base/java.lang.NumberFormatException.forInputString(NumberFormatException.java:67)
> at java.base/java.lang.Integer.parseInt(Integer.java:661)
> at java.base/java.lang.Integer.parseInt(Integer.java:777)
> at
> io.debezium.connector.mysql.MySqlDefaultValueConverter.convert(MySqlDefaultValueConverter.java:XXX)
> at
> io.debezium.connector.mysql.MySqlAntlrDdlParser$MySqlDefaultValueListener.convertDefaultValue(...)
> ...
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
