This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new c9a246b65b6 [fix](mtmv) Fix cancelled tasks with running status
(#39424) (#39489)
c9a246b65b6 is described below
commit c9a246b65b68c65ab7987db839c2298bf98cdbef
Author: zhangdong <[email protected]>
AuthorDate: Fri Aug 16 19:54:16 2024 +0800
[fix](mtmv) Fix cancelled tasks with running status (#39424) (#39489)
pick from master #39424
---
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]
