You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/09/26 06:08:00 UTC

[jira] [Updated] (FLINK-38440) flink-cdc sink iceberg write SMALLINT/TINYINT data wrong

     [ https://issues.apache.org/jira/browse/FLINK-38440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

ASF GitHub Bot updated FLINK-38440:
-----------------------------------
    Labels: Flink-CDC iceberg pull-request-available  (was: Flink-CDC iceberg)

> flink-cdc sink iceberg write SMALLINT/TINYINT data wrong
> --------------------------------------------------------
>
>                 Key: FLINK-38440
>                 URL: https://issues.apache.org/jira/browse/FLINK-38440
>             Project: Flink
>          Issue Type: Bug
>          Components: Flink CDC
>    Affects Versions: 3.0.0
>            Reporter: ChaoFang
>            Priority: Major
>              Labels: Flink-CDC, iceberg, pull-request-available
>
> flink-cdc when mysql -> iceberg, column type in mysql is TINYINT and the value is
> negative( like -1), write to iceberg table the value change to 65535.
>  
> Because -1 pack to "\xff\xff" (short, 2bytes). But in code uppack by int, is get "\xff\xff\x00\x00" (int, 4bytes, got more \x00\x00 from data binary), then get 65535.
>  
> I have fixed this problem
>  
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)