From 723e23aec64af0400046f990faeda43f0ae27c25 Mon Sep 17 00:00:00 2001
From: zwang28 <84491488@qq.com>
Date: Wed, 15 May 2024 14:29:01 +0800
Subject: [PATCH] fix test

---
 .../simulation/tests/integration_tests/batch/mod.rs      | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/src/tests/simulation/tests/integration_tests/batch/mod.rs b/src/tests/simulation/tests/integration_tests/batch/mod.rs
index ef530efa9f46a..616077fea0838 100644
--- a/src/tests/simulation/tests/integration_tests/batch/mod.rs
+++ b/src/tests/simulation/tests/integration_tests/batch/mod.rs
@@ -54,7 +54,7 @@ fn cluster_config_no_compute_nodes() -> Configuration {
         file.write_all(
             "\
 [meta]
-max_heartbeat_interval_secs = 60
+max_heartbeat_interval_secs = 300
 
 [system]
 barrier_interval_ms = 1000
@@ -62,7 +62,10 @@ checkpoint_frequency = 1
 
 [server]
 telemetry_enabled = false
-metrics_level = \"Disabled\"
+metrics_level = \"Disabled\"\
+
+[batch]
+mask_worker_temporary_secs = 30
         "
             .as_bytes(),
         )
@@ -163,7 +166,7 @@ async fn test_serving_cluster_availability() {
     tokio::time::sleep(Duration::from_secs(15)).await;
     query_and_assert(session.clone()).await;
     // wait for mask expire
-    tokio::time::sleep(Duration::from_secs(30)).await;
+    tokio::time::sleep(Duration::from_secs(60)).await;
     session.run(select).await.unwrap_err();
     // wait for previous nodes expire
     tokio::time::sleep(Duration::from_secs(300)).await;