From ad35873d46beff2e47bdbce11d9c59910980a52c Mon Sep 17 00:00:00 2001
From: justinwwhuang <hww_justin@163.com>
Date: Thu, 7 Nov 2024 15:19:44 +0800
Subject: [PATCH] [INLONG-11461][Agent] HeartbeatManager does not create a
 DefaultMessageSender (#11462)

---
 .../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 @@ 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) {