You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Xin Gong (Jira)" <ji...@apache.org> on 2026/07/07 07:33:00 UTC
[jira] [Created] (FLINK-40087) MySqlDefaultValueConverter fails to parse charset-introducer default values wrapped in double quotes and/or containing padding spaces (e.g. `_UTF8MB4" 0 "`)
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)