Jiabao-Sun opened a new pull request, #3: URL: https://github.com/apache/flink-connector-mongodb/pull/3
## What is the purpose of the change Exact-once semantics may not be guaranteed at present on partial reads. We use a number fetchSize to limit the records count for every fetch loop but we didn't record the offset into the split state. When resuming the split reader from a partially completed split, we may re-read some data. In this PR, we record the current reading offset into split state. Skip this offset when restoring to prevent duplicate reading. -- 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]
