[INLONG-10751][Agent] Report Agent process status for backend problem…

… analysis
justinwwhuang · Aug 6, 2024 · cf2d4ce · cf2d4ce
1 parent 472ac8d
commit cf2d4ce
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/store/InstanceStore.java b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/store/InstanceStore.java
@@ -60,7 +60,6 @@ public int getRunningInstanceCount() {
         int count = 0;
         for (KeyValueEntity entity : result) {
             if (entity.getAsInstanceProfile().getState() == InstanceStateEnum.DEFAULT) {
-                LOGGER.info("test123 {}", entity.getAsInstanceProfile().getInstanceId());
                 count++;
             }
         }

diff --git a/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/AgentStatusManager.java b/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/AgentStatusManager.java
@@ -83,6 +83,8 @@ public class AgentStatusManager {
     public static AtomicLong sendPackageCount = new AtomicLong();
     private DefaultMessageSender sender;
     private List<String> statusFieldsPre = Lists.newArrayList();
+    private String processStartupTime = format.format(runtimeMXBean.getStartTime());
+    private String systemStartupTime = ExcuteLinux.exeCmd("who -b|awk '{print $(NF-1), $NF}'").replaceAll("\r|\n", "");
 
     private AgentStatusManager(AgentManager agentManager) {
         this.agentManager = agentManager;
@@ -201,7 +203,7 @@ public List<String> getStatusMessage() {
         fields.add(conf.get(AGENT_CLUSTER_NAME));
         fields.add(conf.get(AGENT_CLUSTER_TAG));
         fields.add(TaskManager.class.getPackage().getImplementationVersion());
-        fields.add(format.format(runtimeMXBean.getStartTime()));
+        fields.add(processStartupTime);
         fields.add(String.valueOf(runtime.availableProcessors()));
         fields.add(String.valueOf(twoDecimal(getProcessCpu())));
         fields.add(String.valueOf(twoDecimal((double) runtime.freeMemory() / GB)));
@@ -220,7 +222,7 @@ public List<String> getStatusMessage() {
         fields.add(agentManager.getTaskManager().getTaskResultMd5());
         fields.add(String.valueOf(agentManager.getTaskManager().getTaskStore().getTasks().size()));
         fields.add(String.valueOf(OffsetManager.getInstance().getRunningInstanceCount()));
-        fields.add(ExcuteLinux.exeCmd("who -b|awk '{print $(NF-1), $NF}'").replaceAll("\r|\n", ""));
+        fields.add(systemStartupTime);
         fields.add(String.valueOf(sendPackageCount.getAndSet(0)));
         fields.add(String.valueOf(sendDataLen.getAndSet(0)));
         fields.add(String.valueOf(MemoryManager.getInstance().getLeft(AGENT_GLOBAL_READER_SOURCE_PERMIT)));