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
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new fd5423145d9 [enhance](mtmv)tasks tvf not getLock (#40816) (#40994)
fd5423145d9 is described below
commit fd5423145d9ea4b22485d85a4d72ed9ea8a60439
Author: zhangdong <[email protected]>
AuthorDate: Thu Sep 19 22:40:17 2024 +0800
[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 +++++
.../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 6287a068857..251760ad614 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 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: [email protected]
For additional commands, e-mail: [email protected]
