in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/MongoSourceReaderContext.java [89:91]
public boolean isOverLimit() { return limit > 0 && readCount.get() >= limit; }