(inlong) branch master updated: [INLONG-11461][Agent] HeartbeatManager does not create a DefaultMessageSender (#11462)

[wenweihuang]

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

wenweihuang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new ad35873d46 [INLONG-11461][Agent] HeartbeatManager does not create a 
DefaultMessageSender (#11462)
ad35873d46 is described below

commit ad35873d46beff2e47bdbce11d9c59910980a52c
Author: justinwwhuang <hww_jus...@163.com>
AuthorDate: Thu Nov 7 15:19:44 2024 +0800

    [INLONG-11461][Agent] HeartbeatManager does not create a 
DefaultMessageSender (#11462)
---
 .../src/main/java/org/apache/inlong/agent/core/HeartbeatManager.java  | 4 ----
 1 file changed, 4 deletions(-)

diff --git 
a/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/HeartbeatManager.java
 
b/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/HeartbeatManager.java
index 2a16bffb0a..d436a32636 100644
--- 
a/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/HeartbeatManager.java
+++ 
b/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/HeartbeatManager.java
@@ -74,7 +74,6 @@ public class HeartbeatManager extends AbstractDaemon 
implements AbstractHeartbea
         httpManager = new HttpManager(conf);
         baseManagerUrl = httpManager.getBaseUrl();
         reportHeartbeatUrl = buildReportHeartbeatUrl(baseManagerUrl);
-        createMessageSender();
     }
 
     public static HeartbeatManager getInstance(AgentManager agentManager) {
@@ -121,9 +120,6 @@ public class HeartbeatManager extends AbstractDaemon 
implements AbstractHeartbea
                     if (LOGGER.isDebugEnabled()) {
                         LOGGER.debug(" {} report heartbeat to manager", 
heartbeatMsg);
                     }
-                    if (sender == null) {
-                        createMessageSender();
-                    }
                     AgentStatusManager.sendStatusMsg(sender);
                     FileStaticManager.sendStaticMsg(sender);
                 } catch (Throwable e) {