adjust code

apache · Jan 3, 2025 · c4189c8 · c4189c8
1 parent 0f875d0
commit c4189c8
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 30 deletions.
diff --git a/...er-server/src/main/java/org/apache/bigtop/manager/server/command/job/ServiceStartJob.java b/...er-server/src/main/java/org/apache/bigtop/manager/server/command/job/ServiceStartJob.java
@@ -51,21 +51,6 @@ public void onSuccess() {
         }
     }
 
-    @Override
-    public void onFailure() {
-        super.onFailure();
-
-        CommandDTO commandDTO = jobContext.getCommandDTO();
-        List<ServiceCommandDTO> serviceCommands = commandDTO.getServiceCommands();
-        for (ServiceCommandDTO serviceCommand : serviceCommands) {
-            Long clusterId = commandDTO.getClusterId();
-            String serviceName = serviceCommand.getServiceName();
-            ServicePO servicePO = serviceDao.findByClusterIdAndName(clusterId, serviceName);
-            servicePO.setStatus(HealthyStatusEnum.UNHEALTHY.getCode());
-            serviceDao.partialUpdateById(servicePO);
-        }
-    }
-
     @Override
     public String getName() {
         return "Start services";

diff --git a/...ger-server/src/main/java/org/apache/bigtop/manager/server/command/job/ServiceStopJob.java b/...ger-server/src/main/java/org/apache/bigtop/manager/server/command/job/ServiceStopJob.java
@@ -51,21 +51,6 @@ public void onSuccess() {
         }
     }
 
-    @Override
-    public void onFailure() {
-        super.onFailure();
-
-        CommandDTO commandDTO = jobContext.getCommandDTO();
-        List<ServiceCommandDTO> serviceCommands = commandDTO.getServiceCommands();
-        for (ServiceCommandDTO serviceCommand : serviceCommands) {
-            Long clusterId = commandDTO.getClusterId();
-            String serviceName = serviceCommand.getServiceName();
-            ServicePO servicePO = serviceDao.findByClusterIdAndName(clusterId, serviceName);
-            servicePO.setStatus(HealthyStatusEnum.UNHEALTHY.getCode());
-            serviceDao.partialUpdateById(servicePO);
-        }
-    }
-
     @Override
     public String getName() {
         return "Stop services";