From 39a8db27f29252d71fefca5d0e5dc5fdf58ecb43 Mon Sep 17 00:00:00 2001
From: zhangdong <493738387@qq.com>
Date: Tue, 27 Feb 2024 15:49:08 +0800
Subject: [PATCH] [fix](mtmv)TVF Query JOB Concurrent Reading and Writing
 Causes Exception #31422

---
 .../java/org/apache/doris/job/extensions/mtmv/MTMVTask.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java
index fa0a88fa93..fd0711b8bc 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java
@@ -179,11 +179,11 @@ public class MTMVTask extends AbstractTask {
                 return;
             }
             Map<TableIf, String> tableWithPartKey = getIncrementalTableMap();
-            this.completedPartitions = Lists.newArrayList();
+            this.completedPartitions = Lists.newCopyOnWriteArrayList();
             int refreshPartitionNum = mtmv.getRefreshPartitionNum();
             long execNum = (needRefreshPartitionIds.size() / refreshPartitionNum) + ((needRefreshPartitionIds.size()
                     % refreshPartitionNum) > 0 ? 1 : 0);
-            this.partitionSnapshots = Maps.newHashMap();
+            this.partitionSnapshots = Maps.newConcurrentMap();
             for (int i = 0; i < execNum; i++) {
                 int start = i * refreshPartitionNum;
                 int end = start + refreshPartitionNum;