Browse Source

[Fix-11413] Cannot set task status to kill if the task is not in running(#11414)

3.1.0-release
Wenjun Ruan 2 years ago committed by GitHub
parent
commit
496c2d4bfa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 4
      dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/task/CommonTaskProcessor.java

4
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/task/CommonTaskProcessor.java

@ -144,12 +144,10 @@ public class CommonTaskProcessor extends BaseTaskProcessor {
if (taskInstance.getState().isFinished()) { if (taskInstance.getState().isFinished()) {
return true; return true;
} }
if (StringUtils.isBlank(taskInstance.getHost())) { // we don't wait the kill response
taskInstance.setState(TaskExecutionStatus.KILL); taskInstance.setState(TaskExecutionStatus.KILL);
taskInstance.setEndTime(new Date()); taskInstance.setEndTime(new Date());
processService.updateTaskInstance(taskInstance); processService.updateTaskInstance(taskInstance);
return true;
}
TaskKillRequestCommand killCommand = new TaskKillRequestCommand(); TaskKillRequestCommand killCommand = new TaskKillRequestCommand();
killCommand.setTaskInstanceId(taskInstance.getId()); killCommand.setTaskInstanceId(taskInstance.getId());

Loading…
Cancel
Save