[GitHub] [flink-connector-mongodb] zentol commented on a diff in pull request #3: [FLINK-31063] Prevent duplicate reading when restoring from a checkpoint.

zentol commented on code in PR #3: URL: https://github.com/apache/flink-connector-mongodb/pull/3#discussion_r691646 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoScanSourceSplitState.java: ## @@ -23,18 +23,19 @@ /** MongoDB

[GitHub] [flink-connector-mongodb] zentol commented on a diff in pull request #3: [FLINK-31063] Prevent duplicate reading when restoring from a checkpoint.

zentol commented on code in PR #3: URL: https://github.com/apache/flink-connector-mongodb/pull/3#discussion_r1109995851 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplitState.java: ## @@ -19,28 +19,19 @@ import org.apac

[GitHub] [flink-connector-mongodb] zentol commented on a diff in pull request #3: [FLINK-31063] Prevent duplicate reading when restoring from a checkpoint.

zentol commented on code in PR #3: URL: https://github.com/apache/flink-connector-mongodb/pull/3#discussion_r1105623716 ## flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumStateSerializerTest.java: ## @@ -76,6 +76,7 @@ pr