(doris) branch master updated: [Fix](Job)TVF Query JOB Concurrent Reading and Writing Causes Exception (#31248)

[kirs]

This is an automated email from the ASF dual-hosted git repository.

kirs 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 faeb4522814 [Fix](Job)TVF Query JOB Concurrent Reading and Writing 
Causes Exception (#31248)
faeb4522814 is described below

commit faeb4522814c91fc237ac33abb6a4d6935be9823
Author: Calvin Kirs <k...@apache.org>
AuthorDate: Thu Feb 22 14:02:17 2024 +0800

    [Fix](Job)TVF Query JOB Concurrent Reading and Writing Causes Exception 
(#31248)
---
 .../src/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 78d7598bf13..8c1d6da3a63 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;
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org