[
https://issues.apache.org/jira/browse/FLINK-31063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688443#comment-17688443
]
Jiabao Sun commented on FLINK-31063:
------------------------------------
Hi [~chesnay], please assign this ticket to me.
> Prevent duplicate reading when restoring from a checkpoint.
> -----------------------------------------------------------
>
> Key: FLINK-31063
> URL: https://issues.apache.org/jira/browse/FLINK-31063
> Project: Flink
> Issue Type: Bug
> Components: Connectors / MongoDB
> Affects Versions: mongodb-1.0.0
> Reporter: Jiabao Sun
> Priority: Major
> Fix For: mongodb-1.0.0
>
>
> 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.
> We should record the current reading offset into split state.
> Skip this offset when restoring to prevent duplicate reading.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
