Skip to content
This repository was archived by the owner on Jan 29, 2022. It is now read-only.

Commit df080df

Browse files
author
Luke Lovett
committed
HADOOP-295 - MongoPaginatingSplitter should set the noTimeout option on its cursor.
1 parent f6f74f9 commit df080df

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

core/src/main/java/com/mongodb/hadoop/splitter/MongoPaginatingSplitter.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22

33
import com.mongodb.BasicDBObject;
44
import com.mongodb.BasicDBObjectBuilder;
5+
import com.mongodb.Bytes;
56
import com.mongodb.DBCollection;
67
import com.mongodb.DBCursor;
78
import com.mongodb.DBObject;
@@ -87,7 +88,8 @@ public List<InputSplit> calculateSplits() throws SplitFailedException {
8788
}
8889
cursor = inputCollection.find(rangeObj, splitKeyProjection);
8990
}
90-
cursor = cursor.sort(splitKeyObj).skip(minDocs).limit(1);
91+
cursor = cursor.sort(splitKeyObj).skip(minDocs).limit(1)
92+
.setOptions(Bytes.QUERYOPTION_NOTIMEOUT);
9193

9294
if (cursor.hasNext()) {
9395
maxBound = cursor.next().get(splitKey);

0 commit comments

Comments
 (0)