Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
kwannoel committed Apr 11, 2024
1 parent 48852a5 commit 54465a8
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions e2e_test/streaming/rate_limit/upstream_amplification.slt
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,9 @@ WITH (
datagen.rows.per.second = '10000'
) FORMAT PLAIN ENCODE JSON;

statement ok
SET BACKGROUND_DDL=true;

statement ok
CREATE SINK sink AS
SELECT x.i1 as i1 FROM source_table x
Expand All @@ -26,6 +29,9 @@ CREATE SINK sink AS
JOIN source_table s3 ON x.i1 = s3.i1
WITH (connector = 'blackhole');

statement ok
SET BACKGROUND_DDL=false;

# The following sequence of FLUSH should be fast, since barrier should be able to bypass sink.
# Otherwise, these FLUSH will take a long time to complete, and trigger timeout.
statement ok
Expand Down

0 comments on commit 54465a8

Please sign in to comment.