You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by we...@apache.org on 2024/11/07 07:19:51 UTC
(inlong) branch master updated: [INLONG-11461][Agent] HeartbeatManager does not create a DefaultMessageSender (#11462)
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 <hw...@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) {