[mongodb][hotfix] Fix pollAwaitTimeMillis does not take effect (#1995)

apache · Mar 24, 2023 · a93db47 · a93db47
1 parent 16df76f
commit a93db47
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...java/com/ververica/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java b/...java/com/ververica/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java
@@ -130,6 +130,8 @@ public void execute(Context context) throws Exception {
                                         .map(this::normalizeHeartbeatRecord)
                                         .orElse(null);
                     }
+                    // update nextUpdateTime
+                    nextUpdate = time.milliseconds() + sourceConfig.getPollAwaitTimeMillis();
                 } else {
                     BsonDocument changeStreamDocument = next.get();
                     MongoNamespace namespace = getMongoNamespace(changeStreamDocument);