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

[enhance](mtmv)when calculating the availability of MTMV, no longer c… (#36617)

Browse Source 
pick: #36507
This commit is contained in:
zhangdong
2024-07-02 14:24:33 +08:00
committed by GitHub
parent 0c8934642e
commit ebc1afed4a
2 changed files with 16 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVRewriteUtil.java
View File

@ -62,8 +62,8 @@ public class MTMVRewriteUtil {
return res;
}
// check mv is normal
if (!(mtmv.getStatus().getState() == MTMVState.NORMAL
&& mtmv.getStatus().getRefreshState() == MTMVRefreshState.SUCCESS)) {
if (mtmv.getStatus().getState() != MTMVState.NORMAL
|| mtmv.getStatus().getRefreshState() == MTMVRefreshState.INIT) {
return res;
}
Map<String, Set<String>> partitionMappings = null;

15
fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVRewriteUtilTest.java
View File

@ -256,7 +256,20 @@ public class MTMVRewriteUtilTest {
};
Collection<Partition> mtmvCanRewritePartitions = MTMVRewriteUtil
.getMTMVCanRewritePartitions(mtmv, ctx, currentTimeMills);
Assert.assertEquals(0, mtmvCanRewritePartitions.size());
Assert.assertEquals(1, mtmvCanRewritePartitions.size());
}
@Test
public void testGetMTMVCanRewritePartitionsRefreshStateInit() {
new Expectations() {
{
status.getRefreshState();
minTimes = 0;
result = MTMVRefreshState.INIT;
}
};
Collection<Partition> mtmvCanRewritePartitions = MTMVRewriteUtil
.getMTMVCanRewritePartitions(mtmv, ctx, currentTimeMills);
Assert.assertEquals(0, mtmvCanRewritePartitions.size());
}
}