yux created FLINK-36114:
---------------------------
Summary: Schema registry should block when handling existing
requests
Key: FLINK-36114
URL: https://issues.apache.org/jira/browse/FLINK-36114
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Reporter: yux
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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)