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)
