[INLONG-11461][Agent] HeartbeatManager does not create a DefaultMessa…

…geSender (#11462)
apache · Nov 7, 2024 · ad35873 · ad35873
1 parent a658a09
commit ad35873
Showing 1 changed file with 0 additions and 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
@@ -74,7 +74,6 @@ private HeartbeatManager(AgentManager agentManager) {
         httpManager = new HttpManager(conf);
         baseManagerUrl = httpManager.getBaseUrl();
         reportHeartbeatUrl = buildReportHeartbeatUrl(baseManagerUrl);
-        createMessageSender();
     }
 
     public static HeartbeatManager getInstance(AgentManager agentManager) {
@@ -121,9 +120,6 @@ private Runnable heartbeatReportThread() {
                     if (LOGGER.isDebugEnabled()) {
                         LOGGER.debug(" {} report heartbeat to manager", heartbeatMsg);
                     }
-                    if (sender == null) {
-                        createMessageSender();
-                    }
                     AgentStatusManager.sendStatusMsg(sender);
                     FileStaticManager.sendStaticMsg(sender);
                 } catch (Throwable e) {