diff --git a/risedev.yml b/risedev.yml index 1b66af00d99d3..cf12e9db35323 100644 --- a/risedev.yml +++ b/risedev.yml @@ -207,6 +207,7 @@ profile: 3etcd-3meta: steps: + - use: minio - use: etcd unsafe-no-fsync: true port: 2388 @@ -234,9 +235,11 @@ profile: port: 25690 dashboard-port: 25691 exporter-port: 21250 + - use: compactor 3etcd-3meta-1cn-1fe: steps: + - use: minio - use: etcd unsafe-no-fsync: true port: 2388 @@ -264,6 +267,7 @@ profile: port: 25690 dashboard-port: 25691 exporter-port: 21250 + - use: compactor - use: compute-node - use: frontend diff --git a/src/meta/src/rpc/server.rs b/src/meta/src/rpc/server.rs index 2b216b8f4906d..d1ce25d941a19 100644 --- a/src/meta/src/rpc/server.rs +++ b/src/meta/src/rpc/server.rs @@ -130,10 +130,16 @@ pub async fn rpc_serve( .map_err(|e| anyhow::anyhow!("failed to connect etcd {}", e))?; let meta_store = Arc::new(EtcdMetaStore::new(client)); + // `with_keep_alive` option will break the long connection in election client. + let mut election_options = ConnectOptions::default(); + if let Some((username, password)) = &credentials { + election_options = election_options.with_user(username, password) + } + let election_client = Arc::new( EtcdElectionClient::new( endpoints, - Some(options), + Some(election_options), auth_enabled, address_info.advertise_addr.clone(), ) diff --git a/src/risedevtool/src/task/etcd_service.rs b/src/risedevtool/src/task/etcd_service.rs index d442a45beb542..1912ce58f5b1b 100644 --- a/src/risedevtool/src/task/etcd_service.rs +++ b/src/risedevtool/src/task/etcd_service.rs @@ -57,8 +57,6 @@ impl EtcdService { .arg(&advertise_peer_urls) .arg("--listen-metrics-urls") .arg(&exporter_urls) - .arg("--name") - .arg("risedev-meta") .arg("--max-txn-ops") .arg("999999") .arg("--max-request-bytes")