[enhance](mtmv)refresh mtmv must add auto (#32522)

This commit is contained in:
zhangdong
2024-03-21 16:27:56 +08:00
committed by yiguolei
parent e7919ab1b6
commit 60eeff8e18
43 changed files with 57 additions and 57 deletions

View File

@ -97,7 +97,7 @@ statementBase
(DISTRIBUTED BY (HASH hashKeys=identifierList | RANDOM) (BUCKETS (INTEGER_VALUE | AUTO))?)?
propertyClause?
AS query #createMTMV
| REFRESH MATERIALIZED VIEW mvName=multipartIdentifier (partitionSpec | COMPLETE)? #refreshMTMV
| REFRESH MATERIALIZED VIEW mvName=multipartIdentifier (partitionSpec | COMPLETE | AUTO) #refreshMTMV
| ALTER MATERIALIZED VIEW mvName=multipartIdentifier ((RENAME newName=identifier)
| (REFRESH (refreshMethod | refreshTrigger | refreshMethod refreshTrigger))
| (SET LEFT_PAREN fileProperties=propertyItemList RIGHT_PAREN)) #alterMTMV

View File

@ -48,7 +48,7 @@ suite("test_agg_table_mtmv") {
"""
sql """
REFRESH MATERIALIZED VIEW ${mvName};
REFRESH MATERIALIZED VIEW ${mvName} AUTO;
"""
def jobName = getJobName(dbName, mvName);

View File

@ -50,7 +50,7 @@ suite("test_base_mtmv") {
def jobName = getJobName("regression_test_mtmv_p0", mvName);
order_qt_status "select Name,State,RefreshState from mv_infos('database'='${dbName}') where Name='${mvName}'"
sql """
REFRESH MATERIALIZED VIEW ${mvName}
REFRESH MATERIALIZED VIEW ${mvName} AUTO
"""
waitingMTMVTaskFinished(jobName)
order_qt_status "select Name,State,RefreshState from mv_infos('database'='${dbName}') where Name='${mvName}'"
@ -64,7 +64,7 @@ suite("test_base_mtmv") {
alter table ${tableName} drop COLUMN new_col;
"""
sql """
REFRESH MATERIALIZED VIEW ${mvName}
REFRESH MATERIALIZED VIEW ${mvName} AUTO
"""
waitingMTMVTaskFinished(jobName)
order_qt_status "select Name,State,RefreshState from mv_infos('database'='${dbName}') where Name='${mvName}'"
@ -86,7 +86,7 @@ suite("test_base_mtmv") {
);
"""
sql """
REFRESH MATERIALIZED VIEW ${mvName}
REFRESH MATERIALIZED VIEW ${mvName} AUTO
"""
waitingMTMVTaskFinished(jobName)
order_qt_status "select Name,State,RefreshState from mv_infos('database'='${dbName}') where Name='${mvName}'"

View File

@ -213,7 +213,7 @@ suite("test_build_mtmv") {
SELECT ${tableName}.username, ${tableNamePv}.pv FROM ${tableName}, ${tableNamePv} WHERE ${tableName}.id=${tableNamePv}.id;
"""
sql """
REFRESH MATERIALIZED VIEW ${mvName}
REFRESH MATERIALIZED VIEW ${mvName} AUTO
"""
jobName = getJobName("regression_test_mtmv_p0", mvName);
println jobName

View File

@ -59,7 +59,7 @@ suite("test_hive_mtmv", "p0,external,hive,external_docker,external_docker_hive")
//refresh other partitions
// current, for hive, auto refresh will not change data
sql """
REFRESH MATERIALIZED VIEW ${mvName}
REFRESH MATERIALIZED VIEW ${mvName} AUTO
"""
waitingMTMVTaskFinished(jobName)
order_qt_refresh_other_partition "SELECT * FROM ${mvName} order by id"

View File

@ -78,7 +78,7 @@ suite("test_hive_olap_mtmv", "p0,external,hive,external_docker,external_docker_h
INSERT INTO ${tableName} VALUES(3,"ff"),(4,"gg");
"""
sql """
REFRESH MATERIALIZED VIEW ${mvName}
REFRESH MATERIALIZED VIEW ${mvName} AUTO
"""
waitingMTMVTaskFinished(jobName)
order_qt_refresh_2 "SELECT * FROM ${mvName} order by id"

View File

@ -63,7 +63,7 @@ suite("test_limit_partition_mtmv") {
assertTrue(showPartitionsResult.toString().contains("p_20380101"))
sql """
REFRESH MATERIALIZED VIEW ${mvName}
REFRESH MATERIALIZED VIEW ${mvName} AUTO
"""
def jobName = getJobName(dbName, mvName);
log.info(jobName)
@ -114,7 +114,7 @@ suite("test_limit_partition_mtmv") {
assertTrue(showPartitionsResult.toString().contains("p_20380101"))
sql """
REFRESH MATERIALIZED VIEW ${mvName}
REFRESH MATERIALIZED VIEW ${mvName} AUTO
"""
jobName = getJobName(dbName, mvName);
log.info(jobName)
@ -164,7 +164,7 @@ suite("test_limit_partition_mtmv") {
assertTrue(showPartitionsResult.toString().contains("p_20380101"))
sql """
REFRESH MATERIALIZED VIEW ${mvName}
REFRESH MATERIALIZED VIEW ${mvName} AUTO
"""
jobName = getJobName(dbName, mvName);
log.info(jobName)
@ -213,7 +213,7 @@ suite("test_limit_partition_mtmv") {
assertTrue(showPartitionsResult.toString().contains("p_20380101_20380103"))
sql """
REFRESH MATERIALIZED VIEW ${mvName}
REFRESH MATERIALIZED VIEW ${mvName} AUTO
"""
jobName = getJobName(dbName, mvName);
log.info(jobName)
@ -226,7 +226,7 @@ suite("test_limit_partition_mtmv") {
alter Materialized View ${mvName} set("partition_sync_limit"="");
"""
sql """
REFRESH MATERIALIZED VIEW ${mvName}
REFRESH MATERIALIZED VIEW ${mvName} AUTO
"""
jobName = getJobName(dbName, mvName);
log.info(jobName)

View File

@ -48,7 +48,7 @@ suite("test_mor_table_mtmv") {
"""
sql """
REFRESH MATERIALIZED VIEW ${mvName};
REFRESH MATERIALIZED VIEW ${mvName} AUTO;
"""
def jobName = getJobName(dbName, mvName);

View File

@ -48,7 +48,7 @@ suite("test_mow_table_mtmv") {
"""
sql """
REFRESH MATERIALIZED VIEW ${mvName};
REFRESH MATERIALIZED VIEW ${mvName} AUTO;
"""
def jobName = getJobName(dbName, mvName);

View File

@ -166,7 +166,7 @@ suite("test_partition_refresh_mtmv") {
assertTrue(showPartitionsResult.toString().contains("p_20170301_20170401"))
sql """
REFRESH MATERIALIZED VIEW ${mvName}
REFRESH MATERIALIZED VIEW ${mvName} AUTO
"""
def jobName = getJobName(dbName, mvName);
log.info(jobName)
@ -212,7 +212,7 @@ suite("test_partition_refresh_mtmv") {
assertTrue(showPartitionsResult.toString().contains("p_3_4"))
sql """
REFRESH MATERIALIZED VIEW ${mvName}
REFRESH MATERIALIZED VIEW ${mvName} AUTO
"""
jobName = getJobName(dbName, mvName);
log.info(jobName)
@ -259,7 +259,7 @@ suite("test_partition_refresh_mtmv") {
assertTrue(showPartitionsResult.toString().contains("_3"))
sql """
REFRESH MATERIALIZED VIEW ${mvName}
REFRESH MATERIALIZED VIEW ${mvName} AUTO
"""
jobName = getJobName(dbName, mvName);
log.info(jobName)
@ -324,7 +324,7 @@ suite("test_partition_refresh_mtmv") {
//refresh other partitions
sql """
REFRESH MATERIALIZED VIEW ${mvName}
REFRESH MATERIALIZED VIEW ${mvName} AUTO
"""
waitingMTMVTaskFinished(jobName)
order_qt_refresh_other_partition "SELECT * FROM ${mvName} order by user_id,age,date,num"
@ -361,7 +361,7 @@ suite("test_partition_refresh_mtmv") {
//refresh other partition ,data will be fresh
sql """
REFRESH MATERIALIZED VIEW ${mvName};
REFRESH MATERIALIZED VIEW ${mvName} AUTO;
"""
waitingMTMVTaskFinished(jobName)
order_qt_refresh_other_table_change_other "SELECT * FROM ${mvName} order by user_id,age,date,num"
@ -369,7 +369,7 @@ suite("test_partition_refresh_mtmv") {
//test base table add partition
sql """alter table ${tableNameNum} ADD PARTITION p201704 VALUES [('2017-04-01'), ('2017-05-01'))"""
sql """
REFRESH MATERIALIZED VIEW ${mvName};
REFRESH MATERIALIZED VIEW ${mvName} AUTO;
"""
waitingMTMVTaskFinished(jobName)
showPartitionsResult = sql """show partitions from ${mvName}"""
@ -379,7 +379,7 @@ suite("test_partition_refresh_mtmv") {
//test base table drop partition
sql """alter table ${tableNameNum} drop PARTITION p201704"""
sql """
REFRESH MATERIALIZED VIEW ${mvName};
REFRESH MATERIALIZED VIEW ${mvName} AUTO;
"""
waitingMTMVTaskFinished(jobName)
showPartitionsResult = sql """show partitions from ${mvName}"""
@ -435,7 +435,7 @@ suite("test_partition_refresh_mtmv") {
select ${tableNameUser}.user_id,${tableNameUser}.age,${tableNameNum}.date,${tableNameNum}.num from ${tableNameUser} join ${tableNameNum} on ${tableNameUser}.user_id = ${tableNameNum}.user_id;
"""
sql """
REFRESH MATERIALIZED VIEW ${mvName};
REFRESH MATERIALIZED VIEW ${mvName} AUTO;
"""
jobName = getJobName(dbName, mvName);
log.info(jobName)
@ -447,7 +447,7 @@ suite("test_partition_refresh_mtmv") {
insert into ${tableNameUser} values(1,9);
"""
sql """
REFRESH MATERIALIZED VIEW ${mvName};
REFRESH MATERIALIZED VIEW ${mvName} AUTO;
"""
waitingMTMVTaskFinished(jobName)
order_qt_exclude_will_not_change "SELECT * FROM ${mvName} order by user_id,age,date,num"

View File

@ -42,7 +42,7 @@ suite("test_task_mtmv") {
SELECT * FROM ${tableName};
"""
sql """
REFRESH MATERIALIZED VIEW ${mvName}
REFRESH MATERIALIZED VIEW ${mvName} AUTO
"""
def jobName = getJobName(dbName, mvName);
waitingMTMVTaskFinished(jobName)

View File

@ -51,7 +51,7 @@ suite("test_workload_group_mtmv") {
"""
order_qt_alter "select MvProperties from mv_infos('database'='${dbName}') where Name='${mvName}'"
sql """
refresh MATERIALIZED VIEW ${mvName};
refresh MATERIALIZED VIEW ${mvName} AUTO;
"""
def jobName = getJobName(dbName, mvName);
logger.info(jobName)

View File

@ -133,7 +133,7 @@ suite("cross_join_list_str_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -124,7 +124,7 @@ suite("cross_join_range_date_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -133,7 +133,7 @@ suite("cross_join_range_number_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -133,7 +133,7 @@ suite("full_join_list_str_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -124,7 +124,7 @@ suite("full_join_range_date_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -133,7 +133,7 @@ suite("full_join_range_number_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -133,7 +133,7 @@ suite("inner_join_list_str_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -124,7 +124,7 @@ suite("inner_join_range_date_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -134,7 +134,7 @@ suite("inner_join_range_number_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -133,7 +133,7 @@ suite("left_anti_join_list_str_increment_create") {
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -124,7 +124,7 @@ suite("left_anti_join_range_date_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -132,7 +132,7 @@ suite("left_anti_join_range_number_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -133,7 +133,7 @@ suite("left_join_list_str_increment_create") {
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -124,7 +124,7 @@ suite("left_join_range_date_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -132,7 +132,7 @@ suite("left_join_range_number_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -133,7 +133,7 @@ suite("left_semi_join_list_str_increment_create") {
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -124,7 +124,7 @@ suite("left_semi_join_range_date_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -132,7 +132,7 @@ suite("left_semi_join_range_number_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -133,7 +133,7 @@ suite("right_anti_join_list_str_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -124,7 +124,7 @@ suite("right_anti_join_range_date_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -133,7 +133,7 @@ suite("right_anti_join_range_number_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -133,7 +133,7 @@ suite("right_join_list_str_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -124,7 +124,7 @@ suite("right_join_range_date_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -133,7 +133,7 @@ suite("right_join_range_number_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -132,7 +132,7 @@ suite("right_semi_join_list_str_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -124,7 +124,7 @@ suite("right_semi_join_range_date_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -133,7 +133,7 @@ suite("right_semi_join_range_number_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -133,7 +133,7 @@ suite("self_conn_list_str_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -124,7 +124,7 @@ suite("self_conn_range_date_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -134,7 +134,7 @@ suite("self_conn_range_number_increment_create") {
"""
}
def refresh_mv = {
sql """refresh MATERIALIZED VIEW ${mv_name}"""
sql """refresh MATERIALIZED VIEW ${mv_name} AUTO"""
}
def delete_mv = {
sql """DROP MATERIALIZED VIEW ${mv_name};"""

View File

@ -123,7 +123,7 @@ suite("test_analyze_mtmv") {
l_partkey,
l_suppkey;
"""
sql """REFRESH MATERIALIZED VIEW mv1"""
sql """REFRESH MATERIALIZED VIEW mv1 AUTO"""
while(true) {
Thread.sleep(1000)
def result = sql """select * from mv_infos("database"="test_analyze_mtmv") where Name="mv1";"""