[fix](export) remove task from map finally (#51171) (#51207)

bp #51171
2025-05-24 17:45:47 +08:00
parent 6513f9e01f
commit 701fc5fa2c
1 changed files with 1 additions and 1 deletions
--- 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();
        }