thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-19 04:42:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix logical error when reading from single-replica cluster using parallel replicas

Browse Source
This commit is contained in:
Michael Kolupaev 2024-12-17 00:55:44 +00:00
parent 0ea5bd9144
commit 57d3fca04b
3 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Interpreters/ClusterProxy/executeQuery.cpp
View File

@ -631,7 +631,8 @@ void executeQueryWithParallelReplicas(
std::move(analyzed_read_from_merge_tree),
local_replica_index.value());
if (!with_parallel_replicas)
/// If there's only one replica or the source is empty, just read locally.
if (!with_parallel_replicas || pools_to_use.size() == 1)
{
query_plan = std::move(*local_plan);
return;

1
tests/queries/0_stateless/03285_parallel_replicas_one_replica.reference Normal file
View File

@ -0,0 +1 @@
1

2
tests/queries/0_stateless/03285_parallel_replicas_one_replica.sql Normal file
View File

@ -0,0 +1,2 @@
create table src (y Int8) engine MergeTree order by y as select 1;
select 1 from (select 2 from src) settings enable_parallel_replicas=1, max_parallel_replicas=2, cluster_for_parallel_replicas='test_shard_localhost';