[
https://issues.apache.org/jira/browse/FLINK-38440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv resolved FLINK-38440.
--------------------------------
Fix Version/s: cdc-3.6.0
Assignee: ChaoFang
Resolution: Fixed
Fixed in master via 682d791538972148c2d9f24f96fc2bd9b1a77666.
> 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
> Assignee: ChaoFang
> Priority: Major
> Labels: Flink-CDC, iceberg, pull-request-available
> Fix For: cdc-3.6.0
>
>
> 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)
