explicit 1

Signed-off-by: Bugen Zhao <[email protected]>
risingwavelabs · Jul 23, 2024 · eca1565 · eca1565
1 parent e798d73
commit eca1565
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,