From 9f20e33d50810f20ea17355512abed0a04a495a2 Mon Sep 17 00:00:00 2001
From: Igor Nikonov <igor@clickhouse.com>
Date: Sun, 14 Jul 2024 17:52:51 +0000
Subject: [PATCH] Fix

---
 src/Processors/QueryPlan/ReadFromRemote.cpp | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/src/Processors/QueryPlan/ReadFromRemote.cpp b/src/Processors/QueryPlan/ReadFromRemote.cpp
index 3da22265c5c..712f714376b 100644
--- a/src/Processors/QueryPlan/ReadFromRemote.cpp
+++ b/src/Processors/QueryPlan/ReadFromRemote.cpp
@@ -456,9 +456,9 @@ void ReadFromParallelRemoteReplicasStep::initializePipeline(QueryPipelineBuilder
 
     std::vector<ConnectionPoolPtr> pools_to_use;
     pools_to_use.reserve(shuffled_pool.size());
-    if (exclude_local_replica)
+    for (const auto & pool : shuffled_pool)
     {
-        for (auto & pool : shuffled_pool)
+        if (exclude_local_replica)
         {
             const auto & hostname = pool.pool->getHost();
             auto it = std::find_if(
@@ -466,9 +466,11 @@ void ReadFromParallelRemoteReplicasStep::initializePipeline(QueryPipelineBuilder
                 end(shard.local_addresses),
                 [&hostname](const Cluster::Address & local_addr) { return hostname == local_addr.host_name; });
             if (it == shard.local_addresses.end())
-            {
                 pools_to_use.push_back(pool.pool);
-            }
+        }
+        else
+        {
+            pools_to_use.push_back(pool.pool);
         }
     }