From 7647cec5093e832ac85c35a85fcb533f8d6c7d11 Mon Sep 17 00:00:00 2001
From: Calvin Kirs <kirs@apache.org>
Date: Thu, 22 Feb 2024 14:02:17 +0800
Subject: [PATCH] [Fix](Job)TVF Query JOB Concurrent Reading and Writing Causes
 Exception (#31248)

---
 .../main/java/org/apache/doris/job/base/AbstractJob.java   | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/base/AbstractJob.java b/fe/fe-core/src/main/java/org/apache/doris/job/base/AbstractJob.java
index 78d7598bf1..8c1d6da3a6 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/job/base/AbstractJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/job/base/AbstractJob.java
@@ -50,6 +50,7 @@ import java.util.Collection;
 import java.util.Comparator;
 import java.util.List;
 import java.util.Set;
+import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 import java.util.stream.Collectors;
@@ -128,7 +129,7 @@ public abstract class AbstractJob<T extends AbstractTask, C> implements Job<T, C
         this.executeSql = executeSql;
     }
 
-    private List<T> runningTasks = new ArrayList<>();
+    private CopyOnWriteArrayList<T> runningTasks = new CopyOnWriteArrayList<>();
 
     private Lock createTaskLock = new ReentrantLock();
 
@@ -140,7 +141,7 @@ public abstract class AbstractJob<T extends AbstractTask, C> implements Job<T, C
         for (T task : runningTasks) {
             task.cancel();
         }
-        runningTasks = new ArrayList<>();
+        runningTasks = new CopyOnWriteArrayList<>();
     }
 
     private static final ImmutableList<String> TITLE_NAMES =
@@ -270,7 +271,7 @@ public abstract class AbstractJob<T extends AbstractTask, C> implements Job<T, C
     public static AbstractJob readFields(DataInput in) throws IOException {
         String jsonJob = Text.readString(in);
         AbstractJob job = GsonUtils.GSON.fromJson(jsonJob, AbstractJob.class);
-        job.runningTasks = new ArrayList<>();
+        job.runningTasks = new CopyOnWriteArrayList();
         job.createTaskLock = new ReentrantLock();
         return job;
     }