lvyanquan commented on PR #4087:
URL: https://github.com/apache/flink-cdc/pull/4087#issuecomment-4095003662
Hi @morozov.
I understand the problem you described now. I'd like to confirm that
similar issues can also occur in scenarios other than adding new tables.
Another possible scenario is that due to missing some table splits, when we
can't find the corresponding matchedSplit in BinlogSplitReader#shouldEmit and
proceed to emit the data anyway, it leads to data duplication.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
