ChaoFang created FLINK-38440:
--------------------------------
Summary: 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
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)
