(flink-cdc) branch master updated: [FLINK-37909][source-connector/mongodb] Fix hearbeat manager not updated after reconnect (#4039)

[yux]

This is an automated email from the ASF dual-hosted git repository.

yux pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


The following commit(s) were added to refs/heads/master by this push:
     new 9c84d64d6 [FLINK-37909][source-connector/mongodb] Fix hearbeat manager 
not updated after reconnect (#4039)
9c84d64d6 is described below

commit 9c84d64d646e02183aa49cba26a0dd7cf6bb3158
Author: Sachin Mittal <sjmit...@users.noreply.github.com>
AuthorDate: Sat Jun 7 20:37:13 2025 +0530

    [FLINK-37909][source-connector/mongodb] Fix hearbeat manager not updated 
after reconnect (#4039)
---
 .../connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java
 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java
index d760a42a8..5bbb4d822 100644
--- 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java
+++ 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java
@@ -121,6 +121,7 @@ public class MongoDBStreamFetchTask implements 
FetchTask<SourceSplitBase> {
                                     "Resume token has expired, fallback to 
timestamp restart mode");
                         }
                         changeStreamCursor = 
openChangeStreamCursor(descriptor, resumeTokenExpires);
+                        heartbeatManager = 
openHeartbeatManagerIfNeeded(changeStreamCursor);
                         next = 
Optional.ofNullable(changeStreamCursor.tryNext());
                     } else {
                         throw e;