You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Youle (Jira)" <ji...@apache.org> on 2024/10/28 12:23:00 UTC
[jira] [Created] (FLINK-36614) mysql cdc will be stuck when the ChangeEventQueue is full at snapshot consume phase
Youle created FLINK-36614:
-----------------------------
Summary: mysql cdc will be stuck when the ChangeEventQueue is full at snapshot consume phase
Key: FLINK-36614
URL: https://issues.apache.org/jira/browse/FLINK-36614
Project: Flink
Issue Type: Bug
Components: Flink CDC
Affects Versions: cdc-3.1.1
Reporter: Youle
Attachments: image-2024-10-28-20-21-11-112.png
Reason: The ChangeEventQueue may get too many events because of little delay of network.
The ChangeEventQueue is writen data to be full before it is called to disconnect the binarylog client connection.
Solve: The data is not necessary when the the task is not running. I think we can avoid the ChangeEventQueue to be full by adding these code lines.
!image-2024-10-28-20-21-11-112.png!
Is it right to work in this way? Can anyone check this?
--
This message was sent by Atlassian Jira
(v8.20.10#820010)