Xin Gong created FLINK-36742:
--------------------------------
Summary: Filter unacked split for no capture tables when task
restore from state
Key: FLINK-36742
URL: https://issues.apache.org/jira/browse/FLINK-36742
Project: Flink
Issue Type: Bug
Components: Flink CDC
Affects Versions: cdc-3.2.0
Reporter: Xin Gong
Fix For: cdc-3.3.0
IncrementalSourceReader could report invalid split to
IncrementalSourceEnumerator when user modify task to remove table and restart.
It will cause SnapshotSplitAssigner#allSnapshotSplitsFinished always be false.
Because
splitFinishedOffsets.size() > assignedSplits.size().
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
