thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-26 01:22:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Return resize processor before aggregating.

Browse Source
This commit is contained in:
Nikolai Kochetov 2019-11-09 12:24:55 +03:00
parent 86894c9570
commit cc16ac3c3c
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1974,7 +1974,7 @@ void InterpreterSelectQuery::executeAggregation(QueryPipeline & pipeline, const
if (pipeline.getNumMainStreams() > 1) if (pipeline.getNumMainStreams() > 1)
{ {
/// Add resize transform to uniformly distribute data between aggregating streams. /// Add resize transform to uniformly distribute data between aggregating streams.
pipeline.resize(pipeline.getNumMainStreams()); // , true); pipeline.resize(pipeline.getNumMainStreams(), true);
auto many_data = std::make_shared<ManyAggregatedData>(pipeline.getNumMainStreams()); auto many_data = std::make_shared<ManyAggregatedData>(pipeline.getNumMainStreams());
auto merge_threads = settings.aggregation_memory_efficient_merge_threads auto merge_threads = settings.aggregation_memory_efficient_merge_threads