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

Fix SortingAggregatedTransform.

Browse Source
This commit is contained in:
Nikolai Kochetov 2019-12-27 15:46:39 +03:00
parent b75771be61
commit 2398dc954c
1 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
dbms/src/Processors/Transforms/MergingAggregatedMemoryEfficientTransform.cpp
View File

@ -429,21 +429,30 @@ IProcessor::Status SortingAggregatedTransform::prepare()
continue;
}
all_finished = false;
//all_finished = false;
in->setNeeded();
if (!in->hasData())
{
need_data = true;
all_finished = false;
continue;
}
auto chunk = in->pull();
addChunk(std::move(chunk), input_num);
if (in->isFinished())
{
is_input_finished[input_num] = true;
}
else
{
/// If chunk was pulled, then we need data from this port.
need_data = true;
addChunk(std::move(chunk), input_num);
all_finished = false;
}
}
if (pushed_to_output)