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 28bfa89e54 [INLONG-10017][Agent] Fix the module update configuration 
bug (#10108)
28bfa89e54 is described below

commit 28bfa89e544bad119c20d0422bca4d88b0539d88
Author: justinwwhuang <[email protected]>
AuthorDate: Mon Apr 29 18:33:50 2024 +0800

    [INLONG-10017][Agent] Fix the module update configuration bug (#10108)
---
 .../src/main/java/org/apache/inlong/agent/installer/ModuleManager.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/ModuleManager.java
 
b/inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/ModuleManager.java
index db0dda7974..cd693436bf 100755
--- 
a/inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/ModuleManager.java
+++ 
b/inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/ModuleManager.java
@@ -413,7 +413,7 @@ public class ModuleManager extends AbstractDaemon {
         if 
(localModule.getPackageConfig().getMd5().equals(managerModule.getPackageConfig().getMd5()))
 {
             LOGGER.info("module {} package md5 no change, will restart and 
save config", localModule.getId());
             restartModule(localModule, managerModule);
-            managerModule.setState(ModuleStateEnum.INSTALLED);
+            managerModule.setState(localModule.getState());
             updateModuleConfig(managerModule);
         } else {
             LOGGER.info("module {} package md5 changed, will reinstall", 
localModule.getId());

Reply via email to