diff --git a/src/main/java/com/dispose/controller/DisposeTaskController.java b/src/main/java/com/dispose/controller/DisposeTaskController.java index 7fe20d56..7d077834 100644 --- a/src/main/java/com/dispose/controller/DisposeTaskController.java +++ b/src/main/java/com/dispose/controller/DisposeTaskController.java @@ -257,7 +257,7 @@ public class DisposeTaskController { TaskInfoRsp rspInfo = new TaskInfoRsp(); reqInfo.getItems().forEach(v -> { - TaskInfoData taskData = TaskInfoData.builder().type(v.getType()).build(); + TaskInfoData taskData = TaskInfoData.builder().type(v.getType()).build(); List> ret = taskService.stopTaskByDisposeNode(Long.parseLong(v.getId()), v.getType()); diff --git a/src/main/java/com/dispose/manager/TaskCacheManager.java b/src/main/java/com/dispose/manager/TaskCacheManager.java index 3c8b32fb..a91229b9 100644 --- a/src/main/java/com/dispose/manager/TaskCacheManager.java +++ b/src/main/java/com/dispose/manager/TaskCacheManager.java @@ -35,9 +35,8 @@ public interface TaskCacheManager { * Remove task error code. * * @param id the id - * @return the error code */ - ErrorCode removeTask(Long id); + void removeTask(Long id); /** * Upgrade task status error code. diff --git a/src/main/java/com/dispose/manager/impl/TaskCacheManagerImpl.java b/src/main/java/com/dispose/manager/impl/TaskCacheManagerImpl.java index 378281ed..7843bbb3 100644 --- a/src/main/java/com/dispose/manager/impl/TaskCacheManagerImpl.java +++ b/src/main/java/com/dispose/manager/impl/TaskCacheManagerImpl.java @@ -72,18 +72,10 @@ public class TaskCacheManagerImpl implements TaskCacheManager { * Remove task error code. * * @param id the id - * @return the error code */ @Override - public ErrorCode removeTask(Long id) { - - if (!taskCacheMap.containsKey(id)) { - return ErrorCode.ERR_OK; - } - + public void removeTask(Long id) { taskCacheMap.remove(id); - - return ErrorCode.ERR_OK; } /**