From 98ccf5cfd9adfc21ca2ffafa6345337131db2c96 Mon Sep 17 00:00:00 2001 From: August Date: Sun, 29 Sep 2024 14:39:26 +0800 Subject: [PATCH] fix cluster limit --- src/tests/simulation/src/main.rs | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/src/tests/simulation/src/main.rs b/src/tests/simulation/src/main.rs index 10a359af6c0c7..7d0547bb014b9 100644 --- a/src/tests/simulation/src/main.rs +++ b/src/tests/simulation/src/main.rs @@ -168,9 +168,17 @@ async fn main() { meta_nodes: args.meta_nodes, sqlite_data_dir: args.sqlite_data_dir, per_session_queries: if args.use_arrangement_backfill { - vec!["SET STREAMING_USE_ARRANGEMENT_BACKFILL = true;".to_string()].into() + vec![ + "SET STREAMING_USE_ARRANGEMENT_BACKFILL = true;".to_string(), + "SET bypass_cluster_limits TO true;".to_string(), + ] + .into() } else { - vec!["SET STREAMING_USE_ARRANGEMENT_BACKFILL = false;".to_string()].into() + vec![ + "SET STREAMING_USE_ARRANGEMENT_BACKFILL = false;".to_string(), + "SET bypass_cluster_limits TO true;".to_string(), + ] + .into() }, ..Default::default() };