From 836d149e90476fe08ce00003d7933890a37c66ce Mon Sep 17 00:00:00 2001 From: Igor Nikonov Date: Wed, 29 Nov 2023 13:42:18 +0000 Subject: [PATCH] Fix: use only one connection per replica --- src/Processors/QueryPlan/ReadFromRemote.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/Processors/QueryPlan/ReadFromRemote.cpp b/src/Processors/QueryPlan/ReadFromRemote.cpp index 9e98d753f05..9ebda210844 100644 --- a/src/Processors/QueryPlan/ReadFromRemote.cpp +++ b/src/Processors/QueryPlan/ReadFromRemote.cpp @@ -277,7 +277,7 @@ void ReadFromRemote::addPipe(Pipes & pipes, const ClusterProxy::SelectStreamFact shard.shard_info.pool, query_string, output_stream->header, context, throttler, scalars, external_tables, stage); remote_query_executor->setLogger(log); - remote_query_executor->setPoolMode(PoolMode::GET_MANY); + remote_query_executor->setPoolMode(PoolMode::GET_ONE); if (!table_func_ptr) remote_query_executor->setMainTable(shard.main_table ? shard.main_table : main_table);