github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-02 07:21:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

mongodb游标默认10分钟限制

Browse Source 
设置游标不超时
This commit is contained in:
zygfengyuwuzu 2019-09-27 12:03:52 +08:00 committed by GitHub
parent 57c8dd8673
commit 50a0a1c5fa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
mongodbreader/src/main/java/com/alibaba/datax/plugin/reader/mongodbreader/MongoDBReader.java
View File

@ -120,7 +120,7 @@ public class MongoDBReader extends Reader {
Document queryFilter = Document.parse(query); Document queryFilter = Document.parse(query);
filter = new Document("$and", Arrays.asList(filter, queryFilter)); filter = new Document("$and", Arrays.asList(filter, queryFilter));
} }
dbCursor = col.find(filter).iterator(); dbCursor = col.find(filter).noCursorTimeout(true).iterator();
while (dbCursor.hasNext()) { while (dbCursor.hasNext()) {
Document item = dbCursor.next(); Document item = dbCursor.next();
Record record = recordSender.createRecord(); Record record = recordSender.createRecord();