thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-19 16:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Polish + comments

Browse Source
This commit is contained in:
Igor Nikonov 2024-07-14 18:46:14 +00:00
parent 9f20e33d50
commit f7befaf68e
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/Processors/QueryPlan/ReadFromRemote.cpp
View File

@ -474,18 +474,17 @@ void ReadFromParallelRemoteReplicasStep::initializePipeline(QueryPipelineBuilder
}
}
pools_to_use.resize(std::min(pools_to_use.size(), all_replicas_count));
// if local plan is used for local replica, we should exclude one remote replica
if (exclude_local_replica && !pools_to_use.empty())
pools_to_use.resize(all_replicas_count - 1);
LOG_DEBUG(
getLogger("ReadFromParallelRemoteReplicasStep"),
"Number of pools to use is {}. Originally {}",
pools_to_use.size(),
shuffled_pool.size());
if (pools_to_use.size() > all_replicas_count)
pools_to_use.resize(all_replicas_count);
if (exclude_local_replica && !pools_to_use.empty())
pools_to_use.resize(all_replicas_count - 1);
if (pools_to_use.empty())
return;
@ -497,7 +496,7 @@ void ReadFromParallelRemoteReplicasStep::initializePipeline(QueryPipelineBuilder
LOG_DEBUG(getLogger("ReadFromParallelRemoteReplicasStep"), "Addresses to use: {}", pool_addresses);
}
/// local replicas has number 0
/// when using local plan for local replica, local replica has 0 number
size_t offset = (exclude_local_replica ? 1 : 0);
for (size_t i = 0 + offset; i < all_replicas_count; ++i)
{