This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 39a8db27f29252d71fefca5d0e5dc5fdf58ecb43 Author: zhangdong <[email protected]> AuthorDate: Tue Feb 27 15:49:08 2024 +0800 [fix](mtmv)TVF Query JOB Concurrent Reading and Writing Causes Exception #31422 --- .../src/main/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 fa0a88fa93d..fd0711b8bc4 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; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
