This is an automated email from the ASF dual-hosted git repository.
yiguolei 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 4a5f3172c91 [fix](mtmv)TVF Query JOB Concurrent Reading and Writing
Causes Exception #31422
4a5f3172c91 is described below
commit 4a5f3172c9109488fbc62ec63108c3287b7e49bd
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]
