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)