[
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)
