(doris) 02/03: [enhance](mtmv)tasks tvf not getLock (#40816)

[dataroaring]

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

dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git

commit c65f3359ff4676eb16bff529deda4c568edfe707
Author: zhangdong <493738...@qq.com>
AuthorDate: Thu Sep 19 15:20:22 2024 +0800

    [enhance](mtmv)tasks tvf not getLock (#40816)
    
    `MTMV.getJob` need `readMvLock()`, we We have added a queryTask method
    in MTMV to avoid obtaining lock
---
 fe/fe-core/src/main/java/org/apache/doris/catalog/MTMV.java          | 5 +++++
 .../src/main/java/org/apache/doris/job/extensions/mtmv/MTMVJob.java  | 2 +-
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/MTMV.java 
b/fe/fe-core/src/main/java/org/apache/doris/catalog/MTMV.java
index c3d36ea3971..beda782ecfa 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/MTMV.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/MTMV.java
@@ -59,6 +59,7 @@ import java.util.Map;
 import java.util.Map.Entry;
 import java.util.Optional;
 import java.util.Set;
+import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.locks.ReentrantReadWriteLock;
 
 
@@ -382,6 +383,10 @@ public class MTMV extends OlapTable {
         return res;
     }
 
+    public ConcurrentLinkedQueue<MTMVTask> getHistoryTasks() {
+        return jobInfo.getHistoryTasks();
+    }
+
     // for test
     public void setRefreshInfo(MTMVRefreshInfo refreshInfo) {
         this.refreshInfo = refreshInfo;
diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVJob.java 
b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVJob.java
index 5d7cf4435b9..add191001f9 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVJob.java
@@ -202,7 +202,7 @@ public class MTMVJob extends AbstractJob<MTMVTask, 
MTMVTaskContext> {
             LOG.warn("get mtmv failed", e);
             return Lists.newArrayList();
         }
-        return Lists.newArrayList(mtmv.getJobInfo().getHistoryTasks());
+        return Lists.newArrayList(mtmv.getHistoryTasks());
     }
 
     @Override


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