database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[enhance](mtmv)tasks tvf not getLock (#40816) (#40994)

Browse Source 
pick: https://github.com/apache/doris/pull/40816
This commit is contained in:
zhangdong
2024-09-19 22:40:17 +08:00
committed by GitHub
parent 7ecf088a61
commit fd5423145d
2 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
fe/fe-core/src/main/java/org/apache/doris/catalog/MTMV.java
View File

@ -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;

2
fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVJob.java
View File

@ -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