explicit 1

Signed-off-by: Bugen Zhao <[email protected]>
risingwavelabs · Jul 19, 2024 · 0b0cb85 · 0b0cb85
1 parent 79a1c12
commit 0b0cb85
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/meta/node/src/server.rs b/src/meta/node/src/server.rs
@@ -495,7 +495,7 @@ pub async fn start_service_as_election_leader(
  prometheus_client,
  prometheus_selector,
  metadata_manager: metadata_manager.clone(),
- compute_clients: ComputeClientPool::adhoc(),
+ compute_clients: ComputeClientPool::new(1), // typically no need for plural clients
  diagnose_command,
  trace_state,
  };

diff --git a/src/meta/src/manager/env.rs b/src/meta/src/manager/env.rs
@@ -388,7 +388,7 @@ impl MetaSrvEnv {
  meta_store_impl: MetaStoreImpl,
  ) -> MetaResult<Self> {
  let idle_manager = Arc::new(IdleManager::new(opts.max_idle_ms));
- let stream_client_pool = Arc::new(StreamClientPool::adhoc());
+ let stream_client_pool = Arc::new(StreamClientPool::new(1)); // typically no need for plural clients
  let event_log_manager = Arc::new(start_event_log_manager(
  opts.event_log_enabled,
  opts.event_log_channel_max_size,