loserwang1024 commented on PR #3134: URL: https://github.com/apache/flink-cdc/pull/3134#issuecomment-2029591998
For example: table A, B, C are finished, and each table includes two snapshot infos. 1. Before stop the job, totalFinishedSplitSize of enumerator and reader is both 6. 2. The enumerator send 4 snapshot infos(A+B) to C. 3. Stop the job, remove table C and then restart C. 4. Enumerator start and remove table C's split which is not included anymore . Thus, totalFinishedSplitSize of enumerator is 4 now. <img width="867" alt="image" src="https://github.com/apache/flink-cdc/assets/125648852/14661451-c1a0-4593-87a8-15a07208de79";> 5. `the split that has not yet completed the meta info synchronization should not be deleted`, thus, totalFinishedSplitSize of reader is still 6. The totalFinishedSplitSize of reader and enumerator is different. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
