|
17 | 17 | package com.oceanbase.odc.service.task.listener; |
18 | 18 |
|
19 | 19 | import java.text.MessageFormat; |
20 | | -import java.util.Collections; |
21 | 20 | import java.util.List; |
22 | 21 | import java.util.Map; |
23 | 22 | import java.util.Optional; |
@@ -76,21 +75,10 @@ public void onEvent(JobTerminateEvent event) { |
76 | 75 | // correct status |
77 | 76 | TaskStatus taskStatus = TerminateProcessor.correctTaskStatus(terminateProcessors, jobEntity.getJobType(), |
78 | 77 | scheduleTask, event.getStatus().convertTaskStatus(), event.getTaskResult()); |
79 | | - if (scheduleTask.getStatus() != taskStatus) { |
80 | | - // CAS |
81 | | - int affectRows = scheduleTaskService.updateStatusById(scheduleTask.getId(), taskStatus, |
82 | | - Collections.singletonList(scheduleTask.getStatus().name())); |
83 | | - if (affectRows > 0) { |
84 | | - log.info("Update schedule task status from {} to {} succeed,scheduleTaskId={}", |
85 | | - scheduleTask.getStatus(), |
86 | | - taskStatus, scheduleTask.getId()); |
87 | | - scheduleTask.setStatus(taskStatus); |
88 | | - } else { |
89 | | - log.info("Update schedule task status from {} to {} failed,scheduleTaskId={}", |
90 | | - scheduleTask.getStatus(), |
91 | | - taskStatus, scheduleTask.getId()); |
92 | | - } |
93 | | - } |
| 78 | + // correct to final status |
| 79 | + scheduleTaskService.updateStatusById(scheduleTask.getId(), taskStatus); |
| 80 | + log.info("Update schedule task status to {} succeed,scheduleTaskId={}", taskStatus, scheduleTask.getId()); |
| 81 | + scheduleTask.setStatus(taskStatus); |
94 | 82 | // Refresh the schedule status after the task is completed. |
95 | 83 | scheduleService.refreshScheduleStatus(Long.parseLong(scheduleTask.getJobName())); |
96 | 84 | // Trigger the alarm if the task is failed or canceled. |
|
0 commit comments