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

[fix](mtmv) Mtmv support set both immediate and starttime (#39573) (#40418)

Browse Source 
pick: https://github.com/apache/doris/pull/39573
This commit is contained in:
zhangdong
2024-09-09 11:13:51 +08:00
committed by GitHub
parent a3eba2aad5
commit ecb75c2e7d
3 changed files with 97 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVJobManager.java
View File

@ -105,14 +105,14 @@ public class MTMVJobManager implements MTMVHookService {
.setInterval(mtmv.getRefreshInfo().getRefreshTriggerInfo().getIntervalTrigger().getInterval());
timerDefinition
.setIntervalUnit(mtmv.getRefreshInfo().getRefreshTriggerInfo().getIntervalTrigger().getTimeUnit());
if (mtmv.getRefreshInfo().getBuildMode().equals(BuildMode.IMMEDIATE)) {
jobExecutionConfiguration.setImmediate(true);
} else if (mtmv.getRefreshInfo().getBuildMode().equals(BuildMode.DEFERRED) && !StringUtils
if (!StringUtils
.isEmpty(mtmv.getRefreshInfo().getRefreshTriggerInfo().getIntervalTrigger().getStartTime())) {
timerDefinition.setStartTimeMs(TimeUtils.timeStringToLong(
mtmv.getRefreshInfo().getRefreshTriggerInfo().getIntervalTrigger().getStartTime()));
}
if (mtmv.getRefreshInfo().getBuildMode().equals(BuildMode.IMMEDIATE)) {
jobExecutionConfiguration.setImmediate(true);
}
jobExecutionConfiguration.setTimerDefinition(timerDefinition);
}