From 701fc5fa2cc3dbb825a0784531164690ec2d5516 Mon Sep 17 00:00:00 2001 From: "Mingyu Chen (Rayner)" Date: Sat, 24 May 2025 17:45:47 +0800 Subject: [PATCH] [fix](export) remove task from map finally (#51171) (#51207) bp #51171 --- .../apache/doris/scheduler/manager/TransientTaskManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/scheduler/manager/TransientTaskManager.java b/fe/fe-core/src/main/java/org/apache/doris/scheduler/manager/TransientTaskManager.java index 5c62caede9..feaf3365a3 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/scheduler/manager/TransientTaskManager.java +++ b/fe/fe-core/src/main/java/org/apache/doris/scheduler/manager/TransientTaskManager.java @@ -63,7 +63,7 @@ public class TransientTaskManager { } public void cancelMemoryTask(Long taskId) throws JobException { - TransientTaskExecutor transientTaskExecutor = taskExecutorMap.get(taskId); + TransientTaskExecutor transientTaskExecutor = taskExecutorMap.remove(taskId); if (transientTaskExecutor != null) { transientTaskExecutor.cancel(); }