[FLINK-35251] SchemaDerivation serializes mapping incorrectly on checkpoint

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: cdc-3.1.0
• Fix Version/s: cdc-3.1.0
• Component/s: Flink CDC
• Labels: pull-request-available
• Assignee: Qingsheng Ren
• Reporter: Qingsheng Ren
• Created: 27/Apr/24 15:07
• Updated: 29/Apr/24 02:25
• Resolved: 29/Apr/24 02:25

Description

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.

Issue Links

• links to: GitHub Pull Request #3267