test: simulate for worker node heartbeat timeout (#7640)

Signed-off-by: Runji Wang <wangrunji0408@163.com>
Co-authored-by: August <pin@singularity-data.com>
Co-authored-by: Shanicky Chen <peng@singularity-data.com>
Co-authored-by: Shanicky Chen <peng@risingwave-labs.com>

ci/workflows/pull-request.yml

@@ -288,7 +288,7 @@ steps:
       #     files: "*-junit.xml"
       #     format: "junit"
       - ./ci/plugins/upload-failure-logs
-    timeout_in_minutes: 18
+    timeout_in_minutes: 25
 
   - label: "misc check"
     command: "ci/scripts/misc-check.sh"

src/compute/src/server.rs

@@ -104,6 +104,7 @@ pub async fn compute_node_serve(
         WorkerType::ComputeNode,
         &advertise_addr,
         opts.parallelism,
+        &config.meta,
     )
     .await
     .unwrap();

src/ctl/src/common/meta_service.rs

@@ -15,6 +15,7 @@
 use std::env;
 
 use anyhow::{bail, Result};
+use risingwave_common::config::MetaConfig;
 use risingwave_common::util::addr::HostAddr;
 use risingwave_pb::common::WorkerType;
 use risingwave_rpc_client::MetaClient;
@@ -58,6 +59,7 @@ Note: the default value of `RW_META_ADDR` is 'http://127.0.0.1:5690'.";
             WorkerType::RiseCtl,
             &get_new_ctl_identity(),
             0,
+            &MetaConfig::default(),
         )
         .await?;
         let worker_id = client.worker_id();

src/frontend/src/session.rs

@@ -190,6 +190,7 @@ impl FrontendEnv {
             WorkerType::Frontend,
             &frontend_address,
             0,
+            &config.meta,
         )
         .await?;
 

src/meta/src/rpc/server.rs

@@ -619,6 +619,8 @@ pub async fn start_service_as_election_leader<S: MetaStore>(
         }
     };
 
+    tracing::info!("Starting meta services");
+
     tonic::transport::Server::builder()
         .layer(MetricsMiddlewareLayer::new(meta_metrics))
         .add_service(HeartbeatServiceServer::new(heartbeat_srv))

src/prost/Cargo.toml

@@ -13,7 +13,7 @@ pbjson = "0.5"
 prost = "0.11"
 prost-helpers = { path = "helpers" }
 serde = { version = "1", features = ["derive"] }
-tonic = { version = "0.2.14", package = "madsim-tonic" }
+tonic = { version = "0.2.18", package = "madsim-tonic" }
 
 [target.'cfg(not(madsim))'.dependencies]
 workspace-hack = { path = "../workspace-hack" }