Xin Gong created FLINK-40087:
--------------------------------
Summary: 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.5.0, cdc-3.4.0, cdc-3.2.1, cdc-3.3.0, cdc-3.1.1,
cdc-3.2.0, cdc-3.1.0, cdc-3.3.1, cdc-3.6.1
Reporter: Xin Gong
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)