Flink CDC Issue Import created FLINK-34870:
----------------------------------------------
Summary: [Bug] MongoCDC checkpoint error
Key: FLINK-34870
URL: https://issues.apache.org/jira/browse/FLINK-34870
Project: Flink
Issue Type: Bug
Components: Flink CDC
Reporter: Flink CDC Issue Import
### Search before asking
- [X] I searched in the
[issues|https://github.com/ververica/flink-cdc-connectors/issues) and found
nothing similar.
### Flink version
1.15.2
### Flink CDC version
2.4.1
### Database and its version
5
### Minimal reproduce step
When MongoCDC starts from a checkpoint, if there have been no data changes
(such as inserts, updates, or deletes] before the checkpoint, starting from the
checkpoint will still initiate the capture of all data. Only after data changes
occur, will the initialization data not be captured.
### What did you expect to see?
After starting from a checkpoint, regardless of whether there have been data
changes in the database, data will be captured starting from the offset.
### What did you see instead?
capture all data
### Anything else?
_No response_
### Are you willing to submit a PR?
- [ ] I'm willing to submit a PR!
---------------- Imported from GitHub ----------------
Url: https://github.com/apache/flink-cdc/issues/3053
Created by: [illsiveblue|https://github.com/illsiveblue]
Labels: bug,
Created at: Thu Feb 01 10:22:33 CST 2024
State: open
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
