in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoScanSourceSplitReader.java [157:162]
public void close() {
if (!closed) {
closed = true;
closeCursor();
}
}