From 50a0a1c5fa0934e0b3d5a4f6328fa6a7a3242629 Mon Sep 17 00:00:00 2001
From: zygfengyuwuzu <zygfengyuwuzu@sina.com>
Date: Fri, 27 Sep 2019 12:03:52 +0800
Subject: [PATCH] =?UTF-8?q?mongodb=E6=B8=B8=E6=A0=87=E9=BB=98=E8=AE=A410?=
 =?UTF-8?q?=E5=88=86=E9=92=9F=E9=99=90=E5=88=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

设置游标不超时
---
 .../datax/plugin/reader/mongodbreader/MongoDBReader.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/mongodbreader/src/main/java/com/alibaba/datax/plugin/reader/mongodbreader/MongoDBReader.java b/mongodbreader/src/main/java/com/alibaba/datax/plugin/reader/mongodbreader/MongoDBReader.java
index ba7f07f4..0403d1fb 100644
--- a/mongodbreader/src/main/java/com/alibaba/datax/plugin/reader/mongodbreader/MongoDBReader.java
+++ b/mongodbreader/src/main/java/com/alibaba/datax/plugin/reader/mongodbreader/MongoDBReader.java
@@ -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();