LvYanquan created FLINK-36452:
---------------------------------
Summary: Avoid EOFException when reading binlog after a large
table has just completed snapshot reading
Key: FLINK-36452
URL: https://issues.apache.org/jira/browse/FLINK-36452
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Affects Versions: cdc-3.3.0
Reporter: LvYanquan
Fix For: cdc-3.3.0
When reading binlog after a large table has just completed snapshot reading, we
will need to compare the binlog position with All previous chunks to determine
if this data has been processed before. However, this process is quite
time-consuming and may lead to EOFException of binlog client.
We should try to shorten the comparison time as much as possible.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
