flink-cdc
flink-cdc copied to clipboard
[FLINK-37710] Use schemas from the state in SchemaOperator
Questions:
- Should we synchronize this request with schema changes? I.e. respond with "success" only if the coordinator is idle; otherwise, respond with "busy" and have the operator retry.