(inlong) branch master updated: [INLONG-10918][Manager] The correct command was not used when reinstalling the installer (#10919)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang 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 89f43c62db [INLONG-10918][Manager] The correct command was not used 
when reinstalling the installer (#10919)
89f43c62db is described below

commit 89f43c62dbb57616210bfe7f47fd5df995b06e90
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Tue Aug 27 16:31:34 2024 +0800

    [INLONG-10918][Manager] The correct command was not used when reinstalling 
the installer (#10919)
---
 .../service/cluster/node/AgentClusterNodeInstallOperator.java       | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/node/AgentClusterNodeInstallOperator.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/node/AgentClusterNodeInstallOperator.java
index 77a848dbb6..06fd1db3ad 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/node/AgentClusterNodeInstallOperator.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/node/AgentClusterNodeInstallOperator.java
@@ -98,6 +98,8 @@ public class AgentClusterNodeInstallOperator implements 
InlongClusterNodeInstall
         try {
             AgentClusterNodeRequest request = (AgentClusterNodeRequest) 
clusterNodeRequest;
             deployInstaller(request, operator);
+            String startCmd = agentInstallPath + INSTALLER_START_CMD;
+            commandExecutor.execRemote(request, startCmd);
         } catch (Exception e) {
             
clusterNodeEntityMapper.updateOperateLogById(clusterNodeRequest.getId(), 
e.getMessage());
             String errMsg = String.format("install agent cluster node failed 
for ip=%s", clusterNodeRequest.getIp());
@@ -115,8 +117,8 @@ public class AgentClusterNodeInstallOperator implements 
InlongClusterNodeInstall
             AgentClusterNodeRequest request = (AgentClusterNodeRequest) 
clusterNodeRequest;
             commandExecutor.rmDir(request, agentInstallPath.substring(0, 
agentInstallPath.lastIndexOf(File.separator)));
             deployInstaller(request, operator);
-            String startCmd = agentInstallPath + INSTALLER_START_CMD;
-            commandExecutor.execRemote(request, startCmd);
+            String reStartCmd = agentInstallPath + INSTALLER_RESTART_CMD;
+            commandExecutor.execRemote(request, reStartCmd);
         } catch (Exception e) {
             
clusterNodeEntityMapper.updateOperateLogById(clusterNodeRequest.getId(), 
e.getMessage());
             String errMsg = String.format("reInstall agent cluster node failed 
for ip=%s", clusterNodeRequest.getIp());