LvYanquan created FLINK-34648: --------------------------------- Summary: Avoid RPC time when apply SchemaChangeEvent to external system Key: FLINK-34648 URL: https://issues.apache.org/jira/browse/FLINK-34648 Project: Flink Issue Type: Improvement Components: Flink CDC Affects Versions: cdc-3.1.0 Reporter: LvYanquan Fix For: cdc-3.1.0
When SchemaOperator receive SchemaChangeEvent, it will send request to SchemaRegistry and wait for applying this SchemaChangeEvent to external system synchronously. However, if this process take too long time, it will cause RPC TimeoutException, and During the process of task recovery, there may be other errors like `AddColumnEvent is already existed`. -- This message was sent by Atlassian Jira (v8.20.10#820010)