From fd5423145d9ea4b22485d85a4d72ed9ea8a60439 Mon Sep 17 00:00:00 2001
From: zhangdong <493738387@qq.com>
Date: Thu, 19 Sep 2024 22:40:17 +0800
Subject: [PATCH] [enhance](mtmv)tasks tvf not getLock (#40816) (#40994)

pick: https://github.com/apache/doris/pull/40816
---
 fe/fe-core/src/main/java/org/apache/doris/catalog/MTMV.java  | 5 +++++
 .../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 6287a06885..251760ad61 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
@@ -58,6 +58,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;
 
 
@@ -411,6 +412,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 5d7cf4435b..add191001f 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