Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
kwannoel committed Apr 29, 2024
1 parent 9850cfb commit 0d1888a
Showing 1 changed file with 12 additions and 12 deletions.
24 changes: 12 additions & 12 deletions e2e_test/source/basic/alter/rate_limit_source_kafka.slt
Original file line number Diff line number Diff line change
Expand Up @@ -47,13 +47,13 @@ statement ok
SET STREAMING_RATE_LIMIT=0;

statement ok
create materialized view mv1 as select count(*) from kafka_source;
create materialized view rl_mv1 as select count(*) from kafka_source;

statement ok
create materialized view mv2 as select count(*) from kafka_source;
create materialized view rl_mv2 as select count(*) from kafka_source;

statement ok
create materialized view mv3 as select count(*) from kafka_source;
create materialized view rl_mv3 as select count(*) from kafka_source;

statement ok
SET STREAMING_RATE_LIMIT=default;
Expand All @@ -64,17 +64,17 @@ statement ok
flush;

query I
select * from mv1;
select * from rl_mv1;
----
0

query I
select * from mv2;
select * from rl_mv2;
----
0

query I
select * from mv3;
select * from rl_mv3;
----
0

Expand All @@ -93,32 +93,32 @@ sleep 3s

skipif in-memory
query I
select count(*) > 0 from mv1;
select count(*) > 0 from rl_mv1;
----
t

skipif in-memory
query I
select count(*) > 0 from mv2;
select count(*) > 0 from rl_mv2;
----
t

skipif in-memory
query I
select count(*) > 0 from mv3;
select count(*) > 0 from rl_mv3;
----
t

############## Cleanup

statement ok
drop materialized view mv1;
drop materialized view rl_mv1;

statement ok
drop materialized view mv2;
drop materialized view rl_mv2;

statement ok
drop materialized view mv3;
drop materialized view rl_mv3;

statement ok
drop source kafka_source;
Expand Down

0 comments on commit 0d1888a

Please sign in to comment.