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

[Chore](regression-test) add createMV action && add some mv case from fe ut MaterializedViewFunctionTest (#16825)

Browse Source 
1. add createMV action
2. add some mv case from fe ut MaterializedViewFunctionTest
3. reduce mv scheduler interval time from 10s to 0.3s
This commit is contained in:
Pxl
2023-02-24 16:35:37 +08:00
committed by GitHub
parent cf5bc9594b
commit 0691586eb7
12 changed files with 409 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/alter/MaterializedViewHandler.java
View File

@ -93,8 +93,10 @@ public class MaterializedViewHandler extends AlterHandler {
private static final Logger LOG = LogManager.getLogger(MaterializedViewHandler.class);
public static final String NEW_STORAGE_FORMAT_INDEX_NAME_PREFIX = "__v2_";
public static int scheduler_interval_millisecond = 333;
public MaterializedViewHandler() {
super("materialized view");
super("materialized view", scheduler_interval_millisecond);
}
// for batch submit rollup job, tableId -> jobId

4
fe/fe-core/src/test/java/org/apache/doris/alter/BatchRollupJobTest.java
View File

@ -92,7 +92,7 @@ public class BatchRollupJobTest {
while (!alterJobV2.getJobState().isFinalState()) {
System.out.println(
"rollup job " + alterJobV2.getJobId() + " is running. state: " + alterJobV2.getJobState());
Thread.sleep(5000);
Thread.sleep(1000);
}
System.out.println("rollup job " + alterJobV2.getJobId() + " is done. state: " + alterJobV2.getJobState());
Assert.assertEquals(AlterJobV2.JobState.FINISHED, alterJobV2.getJobState());
@ -142,7 +142,7 @@ public class BatchRollupJobTest {
while (!alterJobV2.getJobState().isFinalState()) {
System.out.println(
"rollup job " + alterJobV2.getJobId() + " is running. state: " + alterJobV2.getJobState());
Thread.sleep(5000);
Thread.sleep(1000);
}
System.out.println("rollup job " + alterJobV2.getJobId() + " is done. state: " + alterJobV2.getJobState());
Assert.assertEquals(AlterJobV2.JobState.FINISHED, alterJobV2.getJobState());