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

Simplify code

Browse Source
This commit is contained in:
Igor Nikonov 2024-07-19 08:24:29 +00:00
parent 7ad07657a3
commit 6db09e884b
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -491,16 +491,17 @@ void ReadFromParallelRemoteReplicasStep::initializePipeline(QueryPipelineBuilder
addresses.emplace_back(pool->getAddress());
LOG_DEBUG(getLogger("ReadFromParallelRemoteReplicasStep"), "Addresses to use: {}", fmt::join(addresses, ", "));
/// 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 < max_replicas_to_use; ++i)
/// when using local plan for local replica, 0 is assigned to local replica as replica num, - in this case, starting from 1 here
size_t replica_num = (exclude_local_replica ? 1 : 0);
for (const auto & pool : pools_to_use)
{
IConnections::ReplicaInfo replica_info{
/// we should use this number specifically because efficiency of data distribution by consistent hash depends on it.
.number_of_current_replica = i,
.number_of_current_replica = replica_num,
};
++replica_num;
addPipeForSingeReplica(pipes, pools_to_use[i - offset], replica_info);
addPipeForSingeReplica(pipes, pool, replica_info);
}
auto pipe = Pipe::unitePipes(std::move(pipes));