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)

Reply via email to