[
https://issues.apache.org/jira/browse/FLINK-37345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17934434#comment-17934434
]
zexin gong commented on FLINK-37345:
------------------------------------
This problem is caused by the misalignment of MySQL columns and Paimon columns.
> [BUG] ClassCastException
> ------------------------
>
> Key: FLINK-37345
> URL: https://issues.apache.org/jira/browse/FLINK-37345
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: 3.0.0
> Environment: flink cdc pipeline: 3.3.0
> Reporter: zexin gong
> Priority: Major
> Attachments: error.png
>
>
> When using flink-cdc-pipeline to synchronize mysql with paimon, an error
> occurs:
> ClassCastException: class java.lang.Integer cannot be cast to class
> org.apache.paimon.data.BinaryString (java.lang.Integer is in module java.base
> of loader 'bootstrap'; org.apache.paimon.data.BinaryString is in unnamed
> module of loader 'app')
> !error.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)