Skip to content

Commit

Permalink
[UT] fix unstable test_mv_refresh_with_mv_reuse case (StarRocks#53651)
Browse files Browse the repository at this point in the history
Signed-off-by: shuming.li <ming.moriarty@gmail.com>
  • Loading branch information
LiShuMing authored Dec 6, 2024
1 parent 11e384d commit 70483d2
Show file tree
Hide file tree
Showing 2 changed files with 44 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,6 @@ INSERT INTO t1 VALUES
('2020-10-24','2020-10-25 12:12:12','k3','k4',0,1,2,3,4,5,1.1,1.12,2.889);
-- result:
-- !result

CREATE TABLE `t2` (
`k1` date not null,
`k2` datetime not null,
Expand Down Expand Up @@ -72,6 +71,10 @@ from t1 a join t2 b on a.k1=b.k1 group by a.k1, b.k1, a.k3, b.k3, a.k4, b.k4;
-- result:
-- !result
refresh materialized view test_mv0 with sync mode;
[UC] analyze table test_mv0 with sync mode;
-- result:
db_f94db20dc0b44906a3118fe96410cca0.test_mv0 analyze status OK
-- !result
select * from test_mv0 order by 1, 2, 3, 4, 5, 6;
-- result:
2020-10-11 2020-10-11 k3 k3 k4 k4 0 2 3 4
Expand Down Expand Up @@ -101,6 +104,10 @@ from t1 a join t2 b on a.k1=b.k1 group by a.k1, b.k1, a.k3, b.k3;
refresh materialized view test_mv1 with sync mode;
-- result:
-- !result
[UC] analyze table test_mv1 with sync mode;
-- result:
db_f94db20dc0b44906a3118fe96410cca0.test_mv1 analyze status OK
-- !result
select * from test_mv1 order by 1, 2, 3, 4;
-- result:
2020-10-11 2020-10-11 k3 k3 0 2 3 4
Expand Down Expand Up @@ -140,6 +147,10 @@ refresh materialized view test_mv2 with sync mode;
2020-10-21 k3 0 2 3
2020-10-22 k3 1 2 3
-- !result
[UC] analyze table test_mv2 with sync mode;
-- result:
db_f94db20dc0b44906a3118fe96410cca0.test_mv2 analyze status OK
-- !result
select * from test_mv2 order by 1, 2, 3, 4;
-- result:
2020-10-11 k3 0 2 3
Expand Down Expand Up @@ -177,13 +188,21 @@ as
select a.k1 as ak1, sum(a.k6) as sum_k6, sum(b.k7) as sum_k7 from t1 a join t2 b on a.k1=b.k1 group by a.k1;
-- result:
-- !result
refresh materialized view test_mv1 with sync mode;
refresh materialized view test_mv3 with sync mode;
[UC] analyze table test_mv3 with sync mode;
-- result:
db_f94db20dc0b44906a3118fe96410cca0.test_mv3 analyze status OK
-- !result
select * from test_mv3 order by 1;
-- result:
2020-10-11 0 2
2020-10-12 1 2
2020-10-21 0 2
2020-10-22 1 2
-- !result
function: print_hit_materialized_view('select a.k1 as ak1, sum(a.k6) as sum_k6, sum(b.k7) as sum_k7 from t1 a join t2 b on a.k1=b.k1 group by a.k1;', 'test_mv3')
-- result:
False
True
-- !result
select a.k1 as ak1, sum(a.k6) as sum_k6, sum(b.k7) as sum_k7 from t1 a join t2 b on a.k1=b.k1 group by a.k1 order by 1, 2;
-- result:
Expand All @@ -197,4 +216,16 @@ drop table t1;
-- !result
drop table t2;
-- result:
-- !result
drop materialized view test_mv0;
-- result:
-- !result
drop materialized view test_mv1;
-- result:
-- !result
drop materialized view test_mv2;
-- result:
-- !result
drop materialized view test_mv3;
-- result:
-- !result
Original file line number Diff line number Diff line change
Expand Up @@ -61,6 +61,7 @@ as
select a.k1 as ak1, b.k1 as bk1, a.k3 as ak3, b.k3 as bk3, a.k4 as ak4, b.k4 as bk4, sum(a.k6) as sum_k6, sum(b.k7) as sum_k7, sum(a.k8) as sum_k8, sum(b.k9) as sum_k9
from t1 a join t2 b on a.k1=b.k1 group by a.k1, b.k1, a.k3, b.k3, a.k4, b.k4;
refresh materialized view test_mv0 with sync mode;
[UC] analyze table test_mv0 with sync mode;
select * from test_mv0 order by 1, 2, 3, 4, 5, 6;

---- test_mv1 refresh should reuse the materialized view test_mv0
Expand All @@ -76,6 +77,7 @@ select a.k1 as ak1, b.k1 as bk1, a.k3 as ak3, b.k3 as bk3, sum(a.k6) as sum_k6,
from t1 a join t2 b on a.k1=b.k1 group by a.k1, b.k1, a.k3, b.k3;

refresh materialized view test_mv1 with sync mode;
[UC] analyze table test_mv1 with sync mode;
select * from test_mv1 order by 1, 2, 3, 4;
function: print_hit_materialized_view('select a.k1 as ak1, b.k1 as bk1, a.k3 as ak3, b.k3 as bk3, sum(a.k6) as sum_k6, sum(b.k7) as sum_k7, sum(a.k8) as sum_k8, sum(b.k9) as sum_k9 from t1 a join t2 b on a.k1=b.k1 group by a.k1, b.k1, a.k3, b.k3;', 'test_mv1')
select a.k1 as ak1, b.k1 as bk1, a.k3 as ak3, b.k3 as bk3, sum(a.k6) as sum_k6, sum(b.k7) as sum_k7, sum(a.k8) as sum_k8, sum(b.k9) as sum_k9 from t1 a join t2 b on a.k1=b.k1 group by a.k1, b.k1, a.k3, b.k3 order by 1, 2, 3, 4;
Expand All @@ -93,6 +95,7 @@ select a.k1 as ak1, a.k3 as ak3, sum(a.k6) as sum_k6, sum(b.k7) as sum_k7, sum(a
from t1 a join t2 b on a.k1=b.k1 group by a.k1, a.k3;

refresh materialized view test_mv2 with sync mode;
[UC] analyze table test_mv2 with sync mode;
select * from test_mv2 order by 1, 2, 3, 4;
function: print_hit_materialized_view('select a.k1 as ak1, a.k3 as ak3, sum(a.k6) as sum_k6, sum(b.k7) as sum_k7, sum(a.k8) as sum_k8 from t1 a join t2 b on a.k1=b.k1 group by a.k1, a.k3;', 'test_mv2')
select a.k1 as ak1, a.k3 as ak3, sum(a.k6) as sum_k6, sum(b.k7) as sum_k7, sum(a.k8) as sum_k8 from t1 a join t2 b on a.k1=b.k1 group by a.k1, a.k3 order by 1, 2, 3, 4;
Expand All @@ -108,10 +111,15 @@ REFRESH DEFERRED MANUAL
as
select a.k1 as ak1, sum(a.k6) as sum_k6, sum(b.k7) as sum_k7 from t1 a join t2 b on a.k1=b.k1 group by a.k1;

refresh materialized view test_mv1 with sync mode;
refresh materialized view test_mv3 with sync mode;
[UC] analyze table test_mv3 with sync mode;
select * from test_mv3 order by 1;
function: print_hit_materialized_view('select a.k1 as ak1, sum(a.k6) as sum_k6, sum(b.k7) as sum_k7 from t1 a join t2 b on a.k1=b.k1 group by a.k1;', 'test_mv3')
select a.k1 as ak1, sum(a.k6) as sum_k6, sum(b.k7) as sum_k7 from t1 a join t2 b on a.k1=b.k1 group by a.k1 order by 1, 2;

drop table t1;
drop table t2;
drop table t2;
drop materialized view test_mv0;
drop materialized view test_mv1;
drop materialized view test_mv2;
drop materialized view test_mv3;

0 comments on commit 70483d2

Please sign in to comment.