[FLINK-36114] Schema registry should block when handling existing requests

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: cdc-3.1.1
• Fix Version/s: cdc-3.2.0
• Component/s: Flink CDC
• Labels: pull-request-available
• Assignee: yux
• Reporter: yux
• Created: 21/Aug/24 01:29
• Updated: 27/Aug/24 16:58
• Resolved: 22/Aug/24 11:20

Description

Currently, SchemaRegistry asynchronously receives schema change requests from SchemaOperator, and results of multiple requests might got mixed up together, causing incorrect logic flow in multiple parallelism cases.

Changing SchemaRegistry's behavior to accept requests in serial should resolve this problem.

Issue Links

• links to: GitHub Pull Request #3563