Qingsheng Ren created FLINK-35251:
-------------------------------------
Summary: SchemaDerivation serializes mapping incorrectly on
checkpoint
Key: FLINK-35251
URL: https://issues.apache.org/jira/browse/FLINK-35251
Project: Flink
Issue Type: Bug
Components: Flink CDC
Affects Versions: cdc-3.1.0
Reporter: Qingsheng Ren
Assignee: Qingsheng Ren
Fix For: cdc-3.1.0
When schema registry is being serialized on checkpoint, SchemaDerivation
mistakenly use `out.write()` instead of `out.writeInt()` for serializing the
size of derivation mapping. This will cause an EOFException when the job is
recovered from checkpoint.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
