This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new ada521589b8 [fix](mtmv)Fix cancelled tasks with running status (#39424)
ada521589b8 is described below
commit ada521589b8321e1e21f62032cf66884bc8c2657
Author: zhangdong <[email protected]>
AuthorDate: Fri Aug 16 16:49:50 2024 +0800
[fix](mtmv)Fix cancelled tasks with running status (#39424)
The state of writing the log first and changing it later resulted in the
memory state being cancelled and the state after restarting being
running
---
fe/fe-core/src/main/java/org/apache/doris/job/task/AbstractTask.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/job/task/AbstractTask.java
b/fe/fe-core/src/main/java/org/apache/doris/job/task/AbstractTask.java
index 3ccef940caf..f78446aaf85 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/job/task/AbstractTask.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/job/task/AbstractTask.java
@@ -137,8 +137,8 @@ public abstract class AbstractTask implements Task {
@Override
public void cancel() throws JobException {
try {
- executeCancelLogic();
status = TaskStatus.CANCELED;
+ executeCancelLogic();
} catch (Exception e) {
log.warn("cancel task failed, job id is {}, task id is {}", jobId,
taskId, e);
throw new JobException(e);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
