Xin Gong created FLINK-38618:
--------------------------------
Summary: StreamSplitAssigner reassign stream split when scan start
mode is latest-offset and taskmanager failover
Key: FLINK-38618
URL: https://issues.apache.org/jira/browse/FLINK-38618
Project: Flink
Issue Type: Bug
Components: Flink CDC
Affects Versions: cdc-3.5.0, cdc-3.4.0, cdc-3.2.1, cdc-3.3.0, cdc-3.1.1,
cdc-3.2.0, cdc-3.1.0
Reporter: Xin Gong
Fix For: cdc-3.6.0
StreamSplitAssigner reassign stream split when scan start mode is latest-offset
and taskmanager failover.
It can cause offset error and miss data.
MySqlBinlogSplitAssigner had fixed
https://github.com/apache/flink-cdc/pull/1627.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)