From a184fed59d1973250cd019b0f3decdc7ba02da12 Mon Sep 17 00:00:00 2001 From: seawinde Date: Tue, 22 Oct 2024 08:20:40 +0800 Subject: [PATCH] fix regression test --- .../doris/regression/suite/Suite.groovy | 2 + .../where/k123_nereids/k123_nereids.groovy | 2 +- .../suites/nereids_p0/hint/test_use_mv.groovy | 4 +- .../materialized_view_switch.groovy | 10 ++--- .../mv/grouping_sets/grouping_sets.groovy | 28 ++++++------ .../mv/nested/nested_materialized_view.groovy | 2 +- .../mv/ssb/mv_ssb_test.groovy | 26 +++++------ .../mv/tpch/mv_tpch_test.groovy | 44 +++++++++---------- 8 files changed, 60 insertions(+), 58 deletions(-) diff --git a/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy b/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy index b5c1e04d05e5fd..c28036439bb0b8 100644 --- a/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy +++ b/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy @@ -1246,6 +1246,8 @@ class Suite implements GroovyInterceptable { logger.info("status is not success") } Assert.assertEquals("SUCCESS", status) + logger.info("waitingMTMVTaskFinished analyze mv name is " + result.last().get(5)) + sql "analyze table ${result.last().get(6)}.${result.last().get(5)} with sync;" } void waitingMTMVTaskFinishedNotNeedSuccess(String jobName) { diff --git a/regression-test/suites/mv_p0/where/k123_nereids/k123_nereids.groovy b/regression-test/suites/mv_p0/where/k123_nereids/k123_nereids.groovy index 259a586aa5ee5d..ea87477d949080 100644 --- a/regression-test/suites/mv_p0/where/k123_nereids/k123_nereids.groovy +++ b/regression-test/suites/mv_p0/where/k123_nereids/k123_nereids.groovy @@ -96,7 +96,7 @@ suite ("k123p_nereids") { qt_select_mv "select k2,k1=1 from d_table where k1=1 order by k2;" - mv_rewrite_success("select k2,k1=2 from d_table where k1=1 order by k2;", "kwh1") + mv_rewrite_fail("select k2,k1=2 from d_table where k1=1 order by k2;", "kwh1") qt_select_mv "select k2,k1=2 from d_table where k1=1 order by k2;" diff --git a/regression-test/suites/nereids_p0/hint/test_use_mv.groovy b/regression-test/suites/nereids_p0/hint/test_use_mv.groovy index 3885dcf3306fbe..f01fbea16dfc9d 100644 --- a/regression-test/suites/nereids_p0/hint/test_use_mv.groovy +++ b/regression-test/suites/nereids_p0/hint/test_use_mv.groovy @@ -52,9 +52,9 @@ suite("test_use_mv") { ); """ sql """ alter table t1 add rollup r1(k2, k1); """ - waitForRollUpJob("t1", 5000, 1) + waitForRollUpJob("t1", "r1", 15000) sql """ alter table t1 add rollup r2(k2); """ - waitForRollUpJob("t1", 5000, 1) + waitForRollUpJob("t1", "r2", 15000) createMV("create materialized view k1_k2_sumk3 as select k1, k2, sum(v1) from t1 group by k1, k2;") explain { sql """select /*+ no_use_mv */ k1 from t1;""" diff --git a/regression-test/suites/nereids_rules_p0/mv/availability/materialized_view_switch.groovy b/regression-test/suites/nereids_rules_p0/mv/availability/materialized_view_switch.groovy index 22e3c361df9227..467cb664b54729 100644 --- a/regression-test/suites/nereids_rules_p0/mv/availability/materialized_view_switch.groovy +++ b/regression-test/suites/nereids_rules_p0/mv/availability/materialized_view_switch.groovy @@ -134,11 +134,11 @@ suite("materialized_view_switch") { where o_orderdate = '2023-12-10' order by 1, 2, 3, 4, 5; """ - check_mv_rewrite_success(db, mv_name, query, "mv_name") + async_mv_rewrite_success(db, mv_name, query, "mv_name") sql "SET enable_materialized_view_rewrite=false" - check_mv_rewrite_fail(db, mv_name, query, "mv_name") + async_mv_rewrite_fail(db, mv_name, query, "mv_name") sql "SET enable_materialized_view_rewrite=true" - check_mv_rewrite_success(db, mv_name, query, "mv_name") + async_mv_rewrite_success(db, mv_name, query, "mv_name") sql """ DROP MATERIALIZED VIEW IF EXISTS mv_name""" // test when materialized_view_relation_mapping_max_count is 8 @@ -153,7 +153,7 @@ suite("materialized_view_switch") { inner join lineitem t2 on t1.L_ORDERKEY = t2.L_ORDERKEY; """ order_qt_query1_0_before "${query1_0}" - check_mv_rewrite_success(db, mv1_0, query1_0, "mv1_0") + async_mv_rewrite_success(db, mv1_0, query1_0, "mv1_0") order_qt_query1_0_after "${query1_0}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv1_0""" @@ -172,7 +172,7 @@ suite("materialized_view_switch") { inner join lineitem t2 on t1.L_ORDERKEY = t2.L_ORDERKEY; """ order_qt_query1_1_before "${query1_1}" - check_mv_rewrite_fail(db, mv1_1, query1_1, "mv1_1") + async_mv_rewrite_fail(db, mv1_1, query1_1, "mv1_1") order_qt_query1_1_after "${query1_1}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv1_1""" diff --git a/regression-test/suites/nereids_rules_p0/mv/grouping_sets/grouping_sets.groovy b/regression-test/suites/nereids_rules_p0/mv/grouping_sets/grouping_sets.groovy index 6d72b737af5d4e..ec8cecbaf517d0 100644 --- a/regression-test/suites/nereids_rules_p0/mv/grouping_sets/grouping_sets.groovy +++ b/regression-test/suites/nereids_rules_p0/mv/grouping_sets/grouping_sets.groovy @@ -154,7 +154,7 @@ suite("materialized_view_grouping_sets") { GROUPING SETS ((o_orderstatus, o_orderdate), (o_orderpriority), (o_orderstatus), ()); """ order_qt_query1_0_before "${query1_0}" - check_mv_rewrite_success(db, mv1_0, query1_0, "mv1_0") + async_mv_rewrite_success(db, mv1_0, query1_0, "mv1_0") order_qt_query1_0_after "${query1_0}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv1_0""" @@ -187,7 +187,7 @@ suite("materialized_view_grouping_sets") { GROUPING SETS ((o_orderstatus, o_orderdate), (o_orderpriority), (o_orderstatus), ()); """ order_qt_query2_0_before "${query2_0}" - check_mv_rewrite_success(db, mv2_0, query2_0, "mv2_0") + async_mv_rewrite_success(db, mv2_0, query2_0, "mv2_0") order_qt_query2_0_after "${query2_0}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv2_0""" @@ -223,7 +223,7 @@ suite("materialized_view_grouping_sets") { GROUPING SETS ((l_shipdate, o_orderdate, l_partkey), (l_partkey, l_suppkey), (l_suppkey), ()); """ order_qt_query3_0_before "${query3_0}" - check_mv_rewrite_success(db, mv3_0, query3_0, "mv3_0") + async_mv_rewrite_success(db, mv3_0, query3_0, "mv3_0") order_qt_query3_0_after "${query3_0}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv3_0""" @@ -263,7 +263,7 @@ suite("materialized_view_grouping_sets") { GROUPING SETS ((l_shipdate, o_orderdate, l_partkey), (l_partkey, l_suppkey), (l_suppkey), ()); """ order_qt_query4_0_before "${query4_0}" - check_mv_rewrite_success(db, mv4_0, query4_0, "mv4_0") + async_mv_rewrite_success(db, mv4_0, query4_0, "mv4_0") order_qt_query4_0_after "${query4_0}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv4_0""" @@ -294,7 +294,7 @@ suite("materialized_view_grouping_sets") { CUBE (o_orderstatus, o_orderpriority); """ order_qt_query5_0_before "${query5_0}" - check_mv_rewrite_success(db, mv5_0, query5_0, "mv5_0") + async_mv_rewrite_success(db, mv5_0, query5_0, "mv5_0") order_qt_query5_0_after "${query5_0}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv5_0""" @@ -327,7 +327,7 @@ suite("materialized_view_grouping_sets") { CUBE (o_orderstatus, o_orderpriority); """ order_qt_query6_0_before "${query6_0}" - check_mv_rewrite_success(db, mv6_0, query6_0, "mv6_0") + async_mv_rewrite_success(db, mv6_0, query6_0, "mv6_0") order_qt_query6_0_after "${query6_0}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv6_0""" @@ -362,7 +362,7 @@ suite("materialized_view_grouping_sets") { CUBE (t1.l_partkey, t1.l_suppkey, o_orderdate); """ order_qt_query7_0_before "${query7_0}" - check_mv_rewrite_success(db, mv7_0, query7_0, "mv7_0") + async_mv_rewrite_success(db, mv7_0, query7_0, "mv7_0") order_qt_query7_0_after "${query7_0}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv7_0""" @@ -401,7 +401,7 @@ suite("materialized_view_grouping_sets") { CUBE (t1.l_partkey, t1.l_suppkey, o_orderdate); """ order_qt_query8_0_before "${query8_0}" - check_mv_rewrite_success(db, mv8_0, query8_0, "mv8_0") + async_mv_rewrite_success(db, mv8_0, query8_0, "mv8_0") order_qt_query8_0_after "${query8_0}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv8_0""" @@ -433,7 +433,7 @@ suite("materialized_view_grouping_sets") { ROLLUP (o_orderstatus, o_orderpriority); """ order_qt_query9_0_before "${query9_0}" - check_mv_rewrite_success(db, mv9_0, query9_0, "mv9_0") + async_mv_rewrite_success(db, mv9_0, query9_0, "mv9_0") order_qt_query9_0_after "${query9_0}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv9_0""" @@ -466,7 +466,7 @@ suite("materialized_view_grouping_sets") { ROLLUP (o_orderstatus, o_orderpriority); """ order_qt_query10_0_before "${query10_0}" - check_mv_rewrite_success(db, mv10_0, query10_0, "mv10_0") + async_mv_rewrite_success(db, mv10_0, query10_0, "mv10_0") order_qt_query10_0_after "${query10_0}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv10_0""" @@ -501,7 +501,7 @@ suite("materialized_view_grouping_sets") { ROLLUP (t1.l_partkey, t1.l_suppkey, o_orderdate); """ order_qt_query11_0_before "${query11_0}" - check_mv_rewrite_success(db, mv11_0, query11_0, "mv11_0") + async_mv_rewrite_success(db, mv11_0, query11_0, "mv11_0") order_qt_query11_0_after "${query11_0}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv11_0""" @@ -540,7 +540,7 @@ suite("materialized_view_grouping_sets") { ROLLUP (t1.l_partkey, t1.l_suppkey, o_orderdate); """ order_qt_query12_0_before "${query12_0}" - check_mv_rewrite_success(db, mv12_0, query12_0, "mv12_0") + async_mv_rewrite_success(db, mv12_0, query12_0, "mv12_0") order_qt_query12_0_after "${query12_0}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv12_0""" @@ -572,7 +572,7 @@ suite("materialized_view_grouping_sets") { GROUPING SETS ((o_orderstatus, o_orderdate), (o_orderpriority), (o_orderstatus), ()); """ order_qt_query13_0_before "${query13_0}" - check_mv_rewrite_fail(db, mv13_0, query13_0, "mv13_0") + async_mv_rewrite_fail(db, mv13_0, query13_0, "mv13_0") order_qt_query13_0_after "${query13_0}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv13_0""" @@ -604,7 +604,7 @@ suite("materialized_view_grouping_sets") { o_orderstatus, o_orderdate, o_orderpriority; """ order_qt_query14_0_before "${query14_0}" - check_mv_rewrite_fail(db, mv14_0, query14_0, "mv14_0") + async_mv_rewrite_fail(db, mv14_0, query14_0, "mv14_0") order_qt_query14_0_after "${query14_0}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv14_0""" } diff --git a/regression-test/suites/nereids_rules_p0/mv/nested/nested_materialized_view.groovy b/regression-test/suites/nereids_rules_p0/mv/nested/nested_materialized_view.groovy index 572b2567e79df2..942db734543330 100644 --- a/regression-test/suites/nereids_rules_p0/mv/nested/nested_materialized_view.groovy +++ b/regression-test/suites/nereids_rules_p0/mv/nested/nested_materialized_view.groovy @@ -248,7 +248,7 @@ suite("nested_materialized_view") { create_async_mv(db, "mv1_0_inner_mv", mv1_0_inner_mv) async_mv_rewrite_fail(db, mv1_0, query1_0, "mv1_0") - mv_rewrite_all_success_without_check_chosen(query1_0, "mv1_0_inner_mv") + mv_rewrite_success_without_check_chosen(query1_0, "mv1_0_inner_mv") order_qt_query1_1_after "${query1_0}" diff --git a/regression-test/suites/nereids_rules_p0/mv/ssb/mv_ssb_test.groovy b/regression-test/suites/nereids_rules_p0/mv/ssb/mv_ssb_test.groovy index ac8854eba7d193..9e78098be7f1c5 100644 --- a/regression-test/suites/nereids_rules_p0/mv/ssb/mv_ssb_test.groovy +++ b/regression-test/suites/nereids_rules_p0/mv/ssb/mv_ssb_test.groovy @@ -108,7 +108,7 @@ suite("mv_ssb_test") { AND lo_quantity < 25; """ order_qt_query1_1_before "${query1_1}" - check_mv_rewrite_success(db, mv1_1, query1_1, "mv1_1") + async_mv_rewrite_success(db, mv1_1, query1_1, "mv1_1") order_qt_query1_1_after "${query1_1}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv1_1""" @@ -132,7 +132,7 @@ suite("mv_ssb_test") { AND lo_quantity BETWEEN 26 AND 35; """ order_qt_query1_2_before "${query1_2}" - check_mv_rewrite_success(db, mv1_2, query1_2, "mv1_2") + async_mv_rewrite_success(db, mv1_2, query1_2, "mv1_2") order_qt_query1_2_after "${query1_2}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv1_2""" @@ -157,7 +157,7 @@ suite("mv_ssb_test") { AND lo_quantity BETWEEN 26 AND 35; """ order_qt_query1_3before "${query1_3}" - check_mv_rewrite_success(db, mv1_3, query1_3, "mv1_3") + async_mv_rewrite_success(db, mv1_3, query1_3, "mv1_3") order_qt_query1_3_after "${query1_3}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv1_3""" @@ -185,7 +185,7 @@ suite("mv_ssb_test") { ORDER BY d_year, p_brand; """ order_qt_query2_1before "${query2_1}" - check_mv_rewrite_success(db, mv2_1, query2_1, "mv2_1") + async_mv_rewrite_success(db, mv2_1, query2_1, "mv2_1") order_qt_query2_1_after "${query2_1}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv2_1""" @@ -215,7 +215,7 @@ suite("mv_ssb_test") { ORDER BY d_year, p_brand; """ order_qt_query2_2before "${query2_2}" - check_mv_rewrite_success(db, mv2_2, query2_2, "mv2_2") + async_mv_rewrite_success(db, mv2_2, query2_2, "mv2_2") order_qt_query2_2_after "${query2_2}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv2_2""" @@ -242,7 +242,7 @@ suite("mv_ssb_test") { ORDER BY d_year, p_brand; """ order_qt_query2_3before "${query2_3}" - check_mv_rewrite_success(db, mv2_3, query2_3, "mv2_3") + async_mv_rewrite_success(db, mv2_3, query2_3, "mv2_3") order_qt_query2_3_after "${query2_3}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv2_3""" @@ -273,7 +273,7 @@ suite("mv_ssb_test") { ORDER BY d_year ASC, REVENUE DESC; """ order_qt_query3_1before "${query3_1}" - check_mv_rewrite_success(db, mv3_1, query3_1, "mv3_1") + async_mv_rewrite_success(db, mv3_1, query3_1, "mv3_1") order_qt_query3_1_after "${query3_1}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv3_1""" @@ -305,7 +305,7 @@ suite("mv_ssb_test") { ORDER BY d_year ASC, REVENUE DESC; """ order_qt_query3_2before "${query3_2}" - check_mv_rewrite_success(db, mv3_2, query3_2, "mv3_2") + async_mv_rewrite_success(db, mv3_2, query3_2, "mv3_2") order_qt_query3_2_after "${query3_2}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv3_2""" @@ -341,7 +341,7 @@ suite("mv_ssb_test") { ORDER BY d_year ASC, REVENUE DESC; """ order_qt_query3_3before "${query3_3}" - check_mv_rewrite_success(db, mv3_3, query3_3, "mv3_3") + async_mv_rewrite_success(db, mv3_3, query3_3, "mv3_3") order_qt_query3_3_after "${query3_3}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv3_3""" @@ -377,7 +377,7 @@ suite("mv_ssb_test") { ORDER BY d_year ASC, REVENUE DESC; """ order_qt_query3_4before "${query3_4}" - check_mv_rewrite_success(db, mv3_4, query3_4, "mv3_4") + async_mv_rewrite_success(db, mv3_4, query3_4, "mv3_4") order_qt_query3_4_after "${query3_4}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv3_4""" @@ -413,7 +413,7 @@ suite("mv_ssb_test") { ORDER BY d_year, c_nation; """ order_qt_query4_1before "${query4_1}" - check_mv_rewrite_success(db, mv4_1, query4_1, "mv4_1") + async_mv_rewrite_success(db, mv4_1, query4_1, "mv4_1") order_qt_query4_1_after "${query4_1}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv4_1""" @@ -450,7 +450,7 @@ suite("mv_ssb_test") { ORDER BY d_year, s_nation, p_category; """ order_qt_query4_2before "${query4_2}" - check_mv_rewrite_success(db, mv4_2, query4_2, "mv4_2") + async_mv_rewrite_success(db, mv4_2, query4_2, "mv4_2") order_qt_query4_2_after "${query4_2}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv4_2""" @@ -484,7 +484,7 @@ suite("mv_ssb_test") { ORDER BY d_year, s_city, p_brand; """ order_qt_query4_3before "${query4_3}" - check_mv_rewrite_success(db, mv4_3, query4_3, "mv4_3") + async_mv_rewrite_success(db, mv4_3, query4_3, "mv4_3") order_qt_query4_3_after "${query4_3}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv4_3""" } diff --git a/regression-test/suites/nereids_rules_p0/mv/tpch/mv_tpch_test.groovy b/regression-test/suites/nereids_rules_p0/mv/tpch/mv_tpch_test.groovy index e033fbebd899fb..2e89a2124117e9 100644 --- a/regression-test/suites/nereids_rules_p0/mv/tpch/mv_tpch_test.groovy +++ b/regression-test/suites/nereids_rules_p0/mv/tpch/mv_tpch_test.groovy @@ -135,7 +135,7 @@ suite("mv_tpch_test") { l_linestatus; """ order_qt_query1_before "${query1}" - check_mv_rewrite_success(db, mv1, query1, "mv1") + async_mv_rewrite_success(db, mv1, query1, "mv1") order_qt_query1_after "${query1}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv1""" @@ -228,7 +228,7 @@ suite("mv_tpch_test") { """ // contains limit, doesn't support now order_qt_query2_before "${query2}" - check_mv_rewrite_fail(db, mv2, query2, "mv2") + async_mv_rewrite_fail(db, mv2, query2, "mv2") order_qt_query2_after "${query2}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv2""" @@ -286,7 +286,7 @@ suite("mv_tpch_test") { """ // contains limit, doesn't support now order_qt_query3_before "${query3}" - check_mv_rewrite_fail(db, mv3, query3, "mv3") + async_mv_rewrite_fail(db, mv3, query3, "mv3") order_qt_query3_after "${query3}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv3""" @@ -333,7 +333,7 @@ suite("mv_tpch_test") { """ // contains subquery, doesn't support now order_qt_query4_before "${query4}" - check_mv_rewrite_success(db, mv4, query4, "mv4") + async_mv_rewrite_success(db, mv4, query4, "mv4") order_qt_query4_after "${query4}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv4""" @@ -391,7 +391,7 @@ suite("mv_tpch_test") { revenue DESC """ order_qt_query5_before "${query5}" - check_mv_rewrite_success(db, mv5, query5, "mv5") + async_mv_rewrite_success(db, mv5, query5, "mv5") order_qt_query5_after "${query5}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv5""" @@ -417,7 +417,7 @@ suite("mv_tpch_test") { AND l_quantity < 24 """ order_qt_query6_before "${query6}" - check_mv_rewrite_success(db, mv6, query6, "mv6") + async_mv_rewrite_success(db, mv6, query6, "mv6") order_qt_query6_after "${query6}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv6""" @@ -504,7 +504,7 @@ suite("mv_tpch_test") { """ // contains subquery, doesn't support now order_qt_query7_before "${query7}" - check_mv_rewrite_fail(db, mv7, query7, "mv7") + async_mv_rewrite_fail(db, mv7, query7, "mv7") order_qt_query7_after "${query7}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv7""" @@ -588,7 +588,7 @@ suite("mv_tpch_test") { o_year """ order_qt_query8_before "${query8}" - check_mv_rewrite_success(db, mv8, query8, "mv8") + async_mv_rewrite_success(db, mv8, query8, "mv8") order_qt_query8_after "${query8}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv8""" @@ -660,7 +660,7 @@ suite("mv_tpch_test") { o_year DESC """ order_qt_query9_before "${query9}" - check_mv_rewrite_success(db, mv9, query9, "mv9") + async_mv_rewrite_success(db, mv9, query9, "mv9") order_qt_query9_after "${query9}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv9""" @@ -735,7 +735,7 @@ suite("mv_tpch_test") { """ // contains limit, doesn't support now order_qt_query10_before "${query10}" - check_mv_rewrite_fail(db, mv10, query10, "mv10") + async_mv_rewrite_fail(db, mv10, query10, "mv10") order_qt_query10_after "${query10}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv10""" @@ -800,7 +800,7 @@ suite("mv_tpch_test") { """ // contains subquery, doesn't support now order_qt_query11_before "${query11}" - check_mv_rewrite_fail(db, mv11, query11, "mv11") + async_mv_rewrite_fail(db, mv11, query11, "mv11") order_qt_query11_after "${query11}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv11""" @@ -866,7 +866,7 @@ suite("mv_tpch_test") { l_shipmode """ order_qt_query12_before "${query12}" - check_mv_rewrite_success(db, mv12, query12, "mv12") + async_mv_rewrite_success(db, mv12, query12, "mv12") order_qt_query12_after "${query12}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv12""" @@ -917,7 +917,7 @@ suite("mv_tpch_test") { """ // when aggregate rewrite, should only contains one aggregate order_qt_query13_before "${query13}" - check_mv_rewrite_fail(db, mv13, query13, "mv13") + async_mv_rewrite_fail(db, mv13, query13, "mv13") order_qt_query13_after "${query13}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv13""" @@ -951,7 +951,7 @@ suite("mv_tpch_test") { AND l_shipdate < DATE '1995-09-01' + INTERVAL '1' MONTH """ order_qt_query14_before "${query14}" - check_mv_rewrite_success(db, mv14, query14, "mv14") + async_mv_rewrite_success(db, mv14, query14, "mv14") order_qt_query14_after "${query14}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv14""" @@ -998,7 +998,7 @@ suite("mv_tpch_test") { """ // revenue1 in materialized view is view, can not create materialized view support now // order_qt_query15_before "${query15}" -// check_mv_rewrite_fail(db, mv15, query15, "mv15") +// async_mv_rewrite_fail(db, mv15, query15, "mv15") // order_qt_query15_after "${query15}" // sql """ DROP MATERIALIZED VIEW IF EXISTS mv15""" @@ -1067,7 +1067,7 @@ suite("mv_tpch_test") { """ // contains subquery, doesn't support now order_qt_query16_before "${query16}" - check_mv_rewrite_success(db, mv16, query16, "mv16") + async_mv_rewrite_success(db, mv16, query16, "mv16") order_qt_query16_after "${query16}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv16""" @@ -1108,7 +1108,7 @@ suite("mv_tpch_test") { """ // contains subquery, doesn't support now order_qt_query17_before "${query17}" - check_mv_rewrite_fail(db, mv17, query17, "mv17") + async_mv_rewrite_fail(db, mv17, query17, "mv17") order_qt_query17_after "${query17}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv17""" @@ -1185,7 +1185,7 @@ suite("mv_tpch_test") { """ // contains limit, doesn't support now order_qt_query18_before "${query18}" - check_mv_rewrite_fail(db, mv18, query18, "mv18") + async_mv_rewrite_fail(db, mv18, query18, "mv18") order_qt_query18_after "${query18}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv18""" @@ -1264,7 +1264,7 @@ suite("mv_tpch_test") { """ // join condition is not conjunctions, doesn't support now order_qt_query19_before "${query19}" - check_mv_rewrite_fail(db, mv19, query19, "mv19") + async_mv_rewrite_fail(db, mv19, query19, "mv19") order_qt_query19_after "${query19}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv19""" @@ -1339,7 +1339,7 @@ suite("mv_tpch_test") { """ // contains subquery, doesn't support now order_qt_query20_before "${query20}" - check_mv_rewrite_fail(db, mv20, query20, "mv20") + async_mv_rewrite_fail(db, mv20, query20, "mv20") order_qt_query20_after "${query20}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv20""" @@ -1426,7 +1426,7 @@ suite("mv_tpch_test") { """ // contains limit, doesn't support now order_qt_query21_before "${query21}" - check_mv_rewrite_fail(db, mv21, query21, "mv21") + async_mv_rewrite_fail(db, mv21, query21, "mv21") order_qt_query21_after "${query21}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv21""" @@ -1505,7 +1505,7 @@ suite("mv_tpch_test") { """ // contains subquery, doesn't support now order_qt_query22_before "${query22}" - check_mv_rewrite_fail(db, mv22, query22, "mv22") + async_mv_rewrite_fail(db, mv22, query22, "mv22") order_qt_query22_after "${query22}" sql """ DROP MATERIALIZED VIEW IF EXISTS mv22""" }