[INLONG-9997][Agent] Handling situations where the installation packa…

…ge md5 remains unchanged and other parameters md5 change (#9998) * [INLONG-9997][Agent]Handling situations where the installation package md5 remains unchanged and other parameters md5 change * [INLONG-9997][Agent] Handling situations where the installation package md5 remains unchanged and other parameters md5 change
apache · Apr 17, 2024 · c8c050e · c8c050e
1 parent 6b5ab82
commit c8c050e
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/...-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/ModuleManager.java b/...-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/ModuleManager.java
@@ -318,8 +318,10 @@ private void deleteModule(ModuleConfig module) {
     private void updateModule(ModuleConfig localModule, ModuleConfig managerModule) {
         LOGGER.info("update module {} start", localModule.getId());
         if (localModule.getPackageConfig().getMd5().equals(managerModule.getPackageConfig().getMd5())) {
-            LOGGER.info("module {} package md5 no change, will restart", localModule.getId());
+            LOGGER.info("module {} package md5 no change, will restart and save config", localModule.getId());
             restartModule(localModule, managerModule);
+            managerModule.setState(ModuleStateEnum.INSTALLED);
+            updateModuleConfig(managerModule);
         } else {
             LOGGER.info("module {} package md5 changed, will reinstall", localModule.getId());
             deleteModule(localModule);
@@ -346,6 +348,11 @@ private void deleteAndSaveModuleConfig(ModuleConfig module) {
         saveToLocalFile(confPath);
     }
 
+    private void updateModuleConfig(ModuleConfig module) {
+        currentModules.put(module.getId(), module);
+        saveToLocalFile(confPath);
+    }
+
     private boolean saveModuleState(Integer moduleId, ModuleStateEnum state) {
         ModuleConfig module = currentModules.get(moduleId);
         if (module == null) {

diff --git a/...t/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/instance/CommonInstance.java b/...t/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/instance/CommonInstance.java
@@ -70,6 +70,7 @@ public boolean init(Object srcManager, InstanceProfile srcProfile) {
                     profile.getInstanceId(), profile.toJsonStr());
             source = (Source) Class.forName(profile.getSourceClass()).newInstance();
             source.init(profile);
+            source.start();
             sink = (Sink) Class.forName(profile.getSinkClass()).newInstance();
             sink.init(profile);
             inited = true;