[
https://issues.apache.org/jira/browse/FLINK-36656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899667#comment-17899667
]
Ruan Hang commented on FLINK-36656:
-----------------------------------
3.2: 12c36f1ccdd80bdcf068f795e6c8943862a674d5
> Flink CDC treats MySQL Sharding table with boolean type conversion error
> ------------------------------------------------------------------------
>
> Key: FLINK-36656
> URL: https://issues.apache.org/jira/browse/FLINK-36656
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.2.0
> Reporter: Leonard Xu
> Assignee: Leonard Xu
> Priority: Major
> Labels: pull-request-available
> Fix For: cdc-3.3.0, cdc-3.2.1
>
>
> The original MySQL Table
> {code:java}
> CREATE TABLE full_types_0
> (
> id BIGINT,
> tiny1_c TINYINT(1) DEFAULT '0' COMMENT 'test tinyint1',
> boolean_c BOOLEAN DEFAULT '0' COMMENT 'test boolean'
> PRIMARY KEY (id)
> ) DEFAULT CHARSET=utf8;INSERT INTO full_types_0 VALUES (1 true, true );
> CREATE TABLE full_types_1
> (
> id BIGINT,
> tiny1_c TINYINT(1) DEFAULT '0' COMMENT 'test tinyint1',
> boolean_c BOOLEAN DEFAULT '0' COMMENT 'test boolean'
> PRIMARY KEY (id)
> ) DEFAULT CHARSET=utf8;INSERT INTO full_types_1 VALUES (1 true, true ); {code}
> The exception error:
> Caused by: java.lang.NumberFormatException: For input string: "true"
>
> The reason:
> MySQL cdc uses SHOW CREATE TABLE command to build its Flink SQL table'
> schema for existing MySQL table, uses create table DDL statement in binlog to
> build its Flink SQL table' schema for newly-added table. But BOOLEAN type is
> a magic type in MySQL world, you can not obtain BOOLEAN type anymore via show
> create table command, you can only obtain BOOLEAN type in original create
> table DDL statement.
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
