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

Fix crash

Browse Source
This commit is contained in:
Igor Nikonov 2024-06-14 14:06:12 +00:00
parent 245476b34b
commit c2d38b3c93
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -474,9 +474,17 @@ void ReadFromParallelRemoteReplicasStep::initializePipeline(QueryPipelineBuilder
else
all_replicas_count = pools_to_use.size();
chassert(all_replicas_count == pools_to_use.size());
if (exclude_local_replica && !pools_to_use.empty())
pools_to_use.resize(all_replicas_count - 1);
if (pools_to_use.empty())
return;
/// local replicas has number 0
size_t offset = (exclude_local_replica ? 1 : 0);
for (size_t i = 0 + offset; i < all_replicas_count + offset; ++i)
for (size_t i = 0 + offset; i < all_replicas_count; ++i)
{
IConnections::ReplicaInfo replica_info{
.all_replicas_count = all_replicas_count,
@ -484,7 +492,7 @@ void ReadFromParallelRemoteReplicasStep::initializePipeline(QueryPipelineBuilder
.number_of_current_replica = i,
};
addPipeForSingeReplica(pipes, shuffled_pool[i].pool, replica_info);
addPipeForSingeReplica(pipes, pools_to_use[i - offset], replica_info);
}
auto pipe = Pipe::unitePipes(std::move(pipes));