mirror of https://github.com/alibaba/DataX.git
Merge 50a0a1c5fa into 60ea07b730
This commit is contained in:
commit
fa6941240f
|
|
@ -120,7 +120,7 @@ public class MongoDBReader extends Reader {
|
|||
Document queryFilter = Document.parse(query);
|
||||
filter = new Document("$and", Arrays.asList(filter, queryFilter));
|
||||
}
|
||||
dbCursor = col.find(filter).iterator();
|
||||
dbCursor = col.find(filter).noCursorTimeout(true).iterator();
|
||||
while (dbCursor.hasNext()) {
|
||||
Document item = dbCursor.next();
|
||||
Record record = recordSender.createRecord();
|
||||
|
|
|
|||
Loading…
Reference in New Issue