[jira] [Updated] (FLINK-34648) Avoid RPC time when apply SchemaChangeEvent to external system

2024-03-12 Thread LvYanquan (Jira)


 [ 
https://issues.apache.org/jira/browse/FLINK-34648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

LvYanquan updated FLINK-34648:
--
Attachment: 截屏2024-03-12 14.55.09.png

> 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
>Priority: Major
> Fix For: cdc-3.1.0
>
> Attachments: 截屏2024-03-12 14.55.09.png
>
>
> 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)


[jira] [Updated] (FLINK-34648) Avoid RPC time when apply SchemaChangeEvent to external system

2024-03-12 Thread ASF GitHub Bot (Jira)


 [ 
https://issues.apache.org/jira/browse/FLINK-34648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

ASF GitHub Bot updated FLINK-34648:
---
Labels: pull-request-available  (was: )

> 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
>Priority: Major
>  Labels: pull-request-available
> Fix For: cdc-3.1.0
>
> Attachments: 截屏2024-03-12 14.55.09.png
>
>
> 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)