Skip to content

Commit c2770fe

Browse files
zfr9527zfr9527
committed
[test](nerieds)fix sql cache with mtmv test case
1 parent 5d7a278 commit c2770fe

File tree

2 files changed

+39
-1
lines changed

2 files changed

+39
-1
lines changed

‎regression-test/suites/nereids_p0/cache/mtmv_with_sql_cache.groovy‎

Lines changed: 30 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -184,6 +184,7 @@ suite("mtmv_with_sql_cache") {
184184
cur_create_async_partition_mv(dbName, mv_name2, mtmv_sql2, "(id)")
185185
cur_create_async_partition_mv(dbName, mv_name4, mtmv_sql4, "(id)")
186186
cur_create_async_partition_mv(dbName, nested_mv_name1, nested_mtmv_sql1, "(id)")
187+
sleep(10 * 1000)
187188

188189
sql "set enable_nereids_planner=true"
189190
sql "set enable_fallback_to_original_planner=false"
@@ -220,12 +221,14 @@ suite("mtmv_with_sql_cache") {
220221

221222
// rename mtmv
222223
sql """ALTER MATERIALIZED VIEW ${mv_name1} rename ${mv_name3};"""
224+
sleep(10 * 1000)
223225
assertNoCache "select * from ${mv_name3}"
224226
assertNoCache mtmv_sql1
225227
assertHasCache "select * from ${nested_mv_name1}"
226228
assertNoCache nested_mtmv_sql3
227229

228230
sql """ALTER MATERIALIZED VIEW ${mv_name3} rename ${mv_name1};"""
231+
sleep(10 * 1000)
229232
assertHasCache "select * from ${mv_name1}" // Since this SQL query hasn't been executed before, so it's still valid now.
230233
assertNoCache mtmv_sql1
231234
assertHasCache "select * from ${nested_mv_name1}" // nested mtmv don't change
@@ -285,6 +288,8 @@ suite("mtmv_with_sql_cache") {
285288
cur_create_async_partition_mv(dbName, mv_name4, mtmv_sql4, "(id)")
286289
cur_create_async_partition_mv(dbName, nested_mv_name1, nested_mtmv_sql1, "(id)")
287290

291+
sleep(10 * 1000)
292+
288293
sql "set enable_nereids_planner=true"
289294
sql "set enable_fallback_to_original_planner=false"
290295
sql "set enable_sql_cache=true"
@@ -320,6 +325,7 @@ suite("mtmv_with_sql_cache") {
320325

321326
// replace mtmv
322327
sql """ALTER MATERIALIZED VIEW ${mv_name1} REPLACE WITH MATERIALIZED VIEW ${mv_name2};"""
328+
sleep(10 * 1000)
323329
assertNoCache "select * from ${mv_name1}"
324330
assertNoCache "select * from ${mv_name2}"
325331
assertNoCache mtmv_sql1
@@ -328,6 +334,7 @@ suite("mtmv_with_sql_cache") {
328334
assertNoCache nested_mtmv_sql1
329335

330336
sql """ALTER MATERIALIZED VIEW ${mv_name2} REPLACE WITH MATERIALIZED VIEW ${mv_name1};"""
337+
sleep(10 * 1000)
331338
assertNoCache "select * from ${mv_name1}"
332339
assertNoCache "select * from ${mv_name2}"
333340
assertNoCache mtmv_sql1
@@ -399,6 +406,8 @@ suite("mtmv_with_sql_cache") {
399406
cur_create_async_partition_mv(dbName, mv_name4, mtmv_sql4, "(id)")
400407
cur_create_async_partition_mv(dbName, nested_mv_name1, nested_mtmv_sql1, "(id)")
401408

409+
sleep(10 * 1000)
410+
402411
sql "set enable_nereids_planner=true"
403412
sql "set enable_fallback_to_original_planner=false"
404413
sql "set enable_sql_cache=true"
@@ -501,6 +510,8 @@ suite("mtmv_with_sql_cache") {
501510
cur_create_async_partition_mv(dbName, mv_name4, mtmv_sql4, "(id)")
502511
cur_create_async_partition_mv(dbName, nested_mv_name1, nested_mtmv_sql1, "(id)")
503512

513+
sleep(10 * 1000)
514+
504515
sql "set enable_nereids_planner=true"
505516
sql "set enable_fallback_to_original_planner=false"
506517
sql "set enable_sql_cache=true"
@@ -538,6 +549,8 @@ suite("mtmv_with_sql_cache") {
538549
sql "REFRESH MATERIALIZED VIEW ${mv_name1} AUTO;"
539550
waitingMTMVTaskFinishedByMvName(mv_name1)
540551

552+
sleep(10 * 1000)
553+
541554
assertHasCache "select * from ${mv_name1}"
542555
assertHasCache mtmv_sql1
543556
assertHasCache "select * from ${nested_mv_name1}"
@@ -568,7 +581,7 @@ suite("mtmv_with_sql_cache") {
568581
on t1.id = t2.id
569582
"""
570583
def mtmv_sql4 = """
571-
select t1.id as id, t1.value as value1
584+
select t1.id as id, t1.value as value1
572585
from ${tb_name1} as t1
573586
left join ${tb_name2} as t2
574587
on t1.id = t2.id
@@ -593,6 +606,8 @@ suite("mtmv_with_sql_cache") {
593606
cur_create_async_partition_mv(dbName, mv_name4, mtmv_sql4, "(id)")
594607
cur_create_async_partition_mv(dbName, nested_mv_name1, nested_mtmv_sql1, "(id)")
595608

609+
sleep(10 * 1000)
610+
596611
sql "set enable_nereids_planner=true"
597612
sql "set enable_fallback_to_original_planner=false"
598613
sql "set enable_sql_cache=true"
@@ -629,6 +644,8 @@ suite("mtmv_with_sql_cache") {
629644
// refresh mtmv complete
630645
sql "REFRESH MATERIALIZED VIEW ${mv_name1} complete;"
631646
waitingMTMVTaskFinishedByMvName(mv_name1)
647+
sleep(10 * 1000)
648+
632649
assertNoCache "select * from ${mv_name1}"
633650
assertNoCache mtmv_sql1
634651
assertHasCache "select * from ${nested_mv_name1}"
@@ -692,6 +709,8 @@ suite("mtmv_with_sql_cache") {
692709
cur_create_async_partition_mv(dbName, mv_name4, mtmv_sql4, "(id)")
693710
cur_create_async_partition_mv(dbName, nested_mv_name1, nested_mtmv_sql1, "(id)")
694711

712+
sleep(10 * 1000)
713+
695714
sql "set enable_nereids_planner=true"
696715
sql "set enable_fallback_to_original_planner=false"
697716
sql "set enable_sql_cache=true"
@@ -727,6 +746,7 @@ suite("mtmv_with_sql_cache") {
727746

728747
// base table insert overwrite
729748
sql "INSERT OVERWRITE table ${tb_name1} PARTITION(p5) VALUES (5, 6);"
749+
sleep(10 * 1000)
730750
assertHasCache "select * from ${mv_name1}"
731751
assertNoCache mtmv_sql1
732752
assertHasCache "select * from ${nested_mv_name1}"
@@ -737,6 +757,7 @@ suite("mtmv_with_sql_cache") {
737757

738758
sql "REFRESH MATERIALIZED VIEW ${mv_name1} AUTO;"
739759
waitingMTMVTaskFinishedByMvName(mv_name1)
760+
sleep(10 * 1000)
740761
assertNoCache "select * from ${mv_name1}"
741762
assertNoCache mtmv_sql1
742763
assertHasCache "select * from ${nested_mv_name1}"
@@ -799,6 +820,8 @@ suite("mtmv_with_sql_cache") {
799820
cur_create_async_partition_mv(dbName, mv_name4, mtmv_sql4, "(id)")
800821
cur_create_async_partition_mv(dbName, nested_mv_name1, nested_mtmv_sql1, "(id)")
801822

823+
sleep(10 * 1000)
824+
802825
sql "set enable_nereids_planner=true"
803826
sql "set enable_fallback_to_original_planner=false"
804827
sql "set enable_sql_cache=true"
@@ -834,6 +857,7 @@ suite("mtmv_with_sql_cache") {
834857

835858
// add partition
836859
sql "alter table ${tb_name1} add partition p6 values[('6'),('7'))"
860+
sleep(10 * 1000)
837861
assertHasCache "select * from ${mv_name1}"
838862
assertNoCache mtmv_sql1
839863
assertHasCache "select * from ${nested_mv_name1}"
@@ -844,6 +868,7 @@ suite("mtmv_with_sql_cache") {
844868

845869
// base table insert data
846870
sql "insert into ${tb_name1} values(6, 1)"
871+
sleep(10 * 1000)
847872
assertHasCache "select * from ${mv_name1}"
848873
assertNoCache mtmv_sql1 // mtmv no work -> directly base table -> no cache
849874
assertHasCache "select * from ${nested_mv_name1}"
@@ -907,6 +932,8 @@ suite("mtmv_with_sql_cache") {
907932
cur_create_async_partition_mv(dbName, mv_name4, mtmv_sql4, "(id)")
908933
cur_create_async_partition_mv(dbName, nested_mv_name1, nested_mtmv_sql1, "(id)")
909934

935+
sleep(10 * 1000)
936+
910937
sql "set enable_nereids_planner=true"
911938
sql "set enable_fallback_to_original_planner=false"
912939
sql "set enable_sql_cache=true"
@@ -942,6 +969,7 @@ suite("mtmv_with_sql_cache") {
942969

943970
// recreate mtmv to add column
944971
cur_create_async_partition_mv(dbName, mv_name1, mtmv_sql3, "(id)")
972+
sleep(10 * 1000)
945973
assertNoCache "select * from ${mv_name1}"
946974
assertHasCache "select * from ${mv_name2}"
947975
assertNoCache mtmv_sql1
@@ -953,6 +981,7 @@ suite("mtmv_with_sql_cache") {
953981

954982
sql "REFRESH MATERIALIZED VIEW ${mv_name2} AUTO;"
955983
waitingMTMVTaskFinishedByMvName(mv_name2)
984+
sleep(10 * 1000)
956985
assertHasCache "select * from ${mv_name2}"
957986

958987
retryUntilHasSqlCache mtmv_sql1

‎regression-test/suites/nereids_p0/cache/mv_with_sql_cache.groovy‎

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -88,6 +88,7 @@ suite("mv_with_sql_cache") {
8888
def prefix_str = "rename_mv_with_sql_cache_"
8989
def tb_name1 = prefix_str + "table1"
9090
createTestTable tb_name1
91+
sleep(10 * 1000)
9192

9293
def mv_name1 = prefix_str + "mv1"
9394
def new_mv_name1 = prefix_str + "new_mv1"
@@ -114,6 +115,7 @@ suite("mv_with_sql_cache") {
114115
// create mv
115116
create_sync_mv(dbName, tb_name1, mv_name1, mv_sql1)
116117
create_sync_mv(dbName, tb_name1, mv_name2, mv_sql2)
118+
sleep(10 * 1000)
117119

118120
assertHasCache "select * from ${tb_name1}"
119121
assertHasCache mv_sql1
@@ -125,6 +127,7 @@ suite("mv_with_sql_cache") {
125127

126128
// alter rename
127129
sql """ALTER TABLE ${tb_name1} RENAME ROLLUP ${mv_name1} ${new_mv_name1};"""
130+
sleep(10 * 1000)
128131

129132
assertNoCache "select * from ${tb_name1}"
130133
assertNoCache mv_sql1
@@ -148,6 +151,7 @@ suite("mv_with_sql_cache") {
148151
def prefix_str = "create_mv_with_insert_data_sql_cache_"
149152
def tb_name1 = prefix_str + "table1"
150153
createTestTable tb_name1
154+
sleep(10 * 1000)
151155

152156
def mv_name1 = prefix_str + "mv1"
153157
def new_mv_name1 = prefix_str + "new_mv1"
@@ -174,6 +178,7 @@ suite("mv_with_sql_cache") {
174178
// create mv
175179
create_sync_mv(dbName, tb_name1, mv_name1, mv_sql1)
176180
create_sync_mv(dbName, tb_name1, mv_name2, mv_sql2)
181+
sleep(10 * 1000)
177182

178183
assertHasCache "select * from ${tb_name1}"
179184
assertHasCache mv_sql1
@@ -185,6 +190,7 @@ suite("mv_with_sql_cache") {
185190

186191
// insert data
187192
sql """insert into ${tb_name1} values (1, 3);"""
193+
sleep(10 * 1000)
188194
assertNoCache "select * from ${tb_name1}"
189195
sql "select * from ${tb_name1}"
190196
assertHasCache "select * from ${tb_name1}"
@@ -208,6 +214,7 @@ suite("mv_with_sql_cache") {
208214
def prefix_str = "drop_mv_with_sql_cache_"
209215
def tb_name1 = prefix_str + "table1"
210216
createTestTable tb_name1
217+
sleep(10 * 1000)
211218

212219
def mv_name1 = prefix_str + "mv1"
213220
def new_mv_name1 = prefix_str + "new_mv1"
@@ -234,6 +241,7 @@ suite("mv_with_sql_cache") {
234241
// create mv
235242
create_sync_mv(dbName, tb_name1, mv_name1, mv_sql1)
236243
create_sync_mv(dbName, tb_name1, mv_name2, mv_sql2)
244+
sleep(10 * 1000)
237245

238246
assertHasCache "select * from ${tb_name1}"
239247
assertHasCache mv_sql1
@@ -245,6 +253,7 @@ suite("mv_with_sql_cache") {
245253

246254
// drop mv
247255
sql """drop materialized view ${mv_name1} on ${tb_name1};"""
256+
sleep(10 * 1000)
248257

249258
assertHasCache "select * from ${tb_name1}"
250259
assertHasCache mv_sql1

0 commit comments

Comments
 (0)