thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-21 15:12:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

dbms: fixed error with 'max_distributed_connections = 1' [#METR-14855].

Browse Source
This commit is contained in:
Alexey Milovidov 2015-02-01 11:02:18 +03:00
parent a65acf8a03
commit ee98a3babc
3 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dbms/src/Interpreters/InterpreterSelectQuery.cpp
View File

@ -454,13 +454,13 @@ void InterpreterSelectQuery::executeSingleQuery()
settings.limits.max_rows_to_group_by && settings.limits.max_rows_to_group_by &&
settings.limits.group_by_overflow_mode == OverflowMode::ANY && settings.limits.group_by_overflow_mode == OverflowMode::ANY &&
settings.totals_mode != TotalsMode::AFTER_HAVING_EXCLUSIVE; settings.totals_mode != TotalsMode::AFTER_HAVING_EXCLUSIVE;
/// Нужно ли после агрегации сразу финализировать агрегатные функции. /// Нужно ли после агрегации сразу финализировать агрегатные функции.
bool aggregate_final = bool aggregate_final =
need_aggregate && need_aggregate &&
to_stage > QueryProcessingStage::WithMergeableState && to_stage > QueryProcessingStage::WithMergeableState &&
!query.group_by_with_totals; !query.group_by_with_totals;
if (need_aggregate || has_order_by) if (need_aggregate || has_order_by)
do_execute_union = true; do_execute_union = true;
@ -769,10 +769,6 @@ void InterpreterSelectQuery::executeAggregation(BlockInputStreams & streams, Exp
void InterpreterSelectQuery::executeMergeAggregated(BlockInputStreams & streams, bool overflow_row, bool final) void InterpreterSelectQuery::executeMergeAggregated(BlockInputStreams & streams, bool overflow_row, bool final)
{ {
/// Если объединять нечего
if (streams.size() == 1)
return;
/// Склеим несколько источников в один /// Склеим несколько источников в один
executeUnion(streams); executeUnion(streams);

1
dbms/tests/queries/0_stateless/00123_unmerged_result_when_max_distributed_connections_is_one.reference Normal file
View File

@ -0,0 +1 @@
3

2
dbms/tests/queries/0_stateless/00123_unmerged_result_when_max_distributed_connections_is_one.sql Normal file
View File

@ -0,0 +1,2 @@
SET max_distributed_connections = 1;
SELECT count() + 1 FROM remote('127.0.0.{1,2}', system, one);