[BugFix](MTMV)Set enable_mtmv_scheduler_framework master only to avoid regression fail (#18473)

Set enable_mtmv_scheduler_framework master only to avoid regression fail
This commit is contained in:
huangzhaowei
2023-04-09 08:47:18 +08:00
committed by GitHub
parent 60c0bbe272
commit 09d98c1663
11 changed files with 10 additions and 19 deletions

View File

@ -1827,7 +1827,7 @@ public class Config extends ConfigBase {
/*
* mtmv scheduler framework is still under dev, remove this config when it is graduate.
*/
@ConfField(mutable = true)
@ConfField(mutable = true, masterOnly = true)
public static boolean enable_mtmv_scheduler_framework = false;
/* Max running task num at the same time, otherwise the submitted task will still be keep in pending poll*/

View File

@ -76,3 +76,6 @@ use_fuzzy_session_variable=true
enable_map_type=true
enable_struct_type=true
# enable mtmv job
enable_mtmv_scheduler_framework = true

View File

@ -74,3 +74,6 @@ tablet_create_timeout_second=100
remote_fragment_exec_timeout_ms=60000
fuzzy_test_type=p1
use_fuzzy_session_variable=true
# enable mtmv job
enable_mtmv_scheduler_framework = true

View File

@ -3,7 +3,7 @@ BUILD IMMEDIATE REFRESH COMPLETE
DISTRIBUTED BY HASH(c_nation) BUCKETS 6
PROPERTIES ('replication_num' = '1')
AS
SELECT /*+SET_VAR(parallel_fragment_exec_instance_num=4, enable_vectorized_engine=true, batch_size=4096, enable_cost_based_join_reorder=true, enable_projection=true) */
SELECT /*+SET_VAR(parallel_fragment_exec_instance_num=4, batch_size=4096) */
d_year,
c_nation,
SUM(lo_revenue - lo_supplycost) AS PROFIT

View File

@ -3,7 +3,7 @@ BUILD IMMEDIATE REFRESH COMPLETE
DISTRIBUTED BY HASH(s_nation, p_category) BUCKETS 6
PROPERTIES ('replication_num' = '1')
AS
SELECT /*+SET_VAR(parallel_fragment_exec_instance_num=2, enable_vectorized_engine=true, batch_size=4096, enable_cost_based_join_reorder=true, enable_projection=true) */
SELECT /*+SET_VAR(parallel_fragment_exec_instance_num=2, batch_size=4096) */
d_year,
s_nation,
p_category,

View File

@ -3,7 +3,7 @@ BUILD IMMEDIATE REFRESH COMPLETE
DISTRIBUTED BY HASH(s_city, p_brand) BUCKETS 6
PROPERTIES ('replication_num' = '1')
AS
SELECT /*+SET_VAR(parallel_fragment_exec_instance_num=2, enable_vectorized_engine=true, batch_size=4096, enable_cost_based_join_reorder=true, enable_projection=true) */
SELECT /*+SET_VAR(parallel_fragment_exec_instance_num=2, batch_size=4096) */
d_year,
s_city,
p_brand,

View File

@ -17,9 +17,6 @@
suite("test_mtmv_ssb_ddl") {
def ssb_tables = ["customer", "lineorder", "part", "date", "supplier"]
sql """
ADMIN SET FRONTEND CONFIG("enable_mtmv_scheduler_framework"="true");
"""
for (String table in ssb_tables) {
sql new File("""${context.file.parent}/ddl/${table}_create.sql""").text

View File

@ -19,9 +19,6 @@ suite("test_alter_mtmv") {
def tableName = "t_test_alter_mtmv_user"
def tableNamePv = "t_test_alter_mtmv_pv"
def mvName = "multi_mv_test_alter_mtmv"
sql """
ADMIN SET FRONTEND CONFIG("enable_mtmv_scheduler_framework"="true");
"""
sql """drop table if exists `${tableName}`"""
sql """drop table if exists `${tableNamePv}`"""

View File

@ -19,9 +19,6 @@ suite("test_create_both_mtmv") {
def tableName = "t_test_create_both_mtmv_user"
def tableNamePv = "t_test_create_both_mtmv_user_pv"
def mvName = "multi_mv_test_create_both_mtmv"
sql """
ADMIN SET FRONTEND CONFIG("enable_mtmv_scheduler_framework"="true");
"""
sql """drop table if exists `${tableName}`"""
sql """drop table if exists `${tableNamePv}`"""

View File

@ -19,9 +19,6 @@ suite("test_create_mtmv") {
def tableName = "t_test_create_mtmv_user"
def tableNamePv = "t_test_create_mtmv_user_pv"
def mvName = "multi_mv_test_create_mtmv"
sql """
ADMIN SET FRONTEND CONFIG("enable_mtmv_scheduler_framework"="true");
"""
sql """drop table if exists `${tableName}`"""
sql """drop table if exists `${tableNamePv}`"""

View File

@ -19,9 +19,6 @@ suite("test_refresh_mtmv") {
def tableName = "t_test_refresh_mtmv_user"
def tableNamePv = "t_test_refresh_mtmv_user_pv"
def mvName = "multi_mv_test_refresh_mtmv"
sql """
ADMIN SET FRONTEND CONFIG("enable_mtmv_scheduler_framework"="true");
"""
sql """drop table if exists `${tableName}`"""
sql """drop table if exists `${tableNamePv}`"""