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

[yux]

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

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


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

commit d3e54edeab9b43a031981c77022c3107353d3410
Author: Sachin Mittal <sjmit...@users.noreply.github.com>
AuthorDate: Sun Jun 8 11:01:22 2025 +0530

    [FLINK-37909][source-connector/mongodb] Fix hearbeat manager not updated 
after reconnect
---
 .../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;