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

Try fix totals port for IAccumulatingTransform.

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-09-10 10:36:29 +03:00
parent 4f0bb6b91b
commit 7fb45461d1
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/Processors/IAccumulatingTransform.cpp
View File

@ -49,13 +49,15 @@ IAccumulatingTransform::Status IAccumulatingTransform::prepare()
return Status::Finished;
}
/// Close input if flag was set manually.
if (input.isFinished())
finished_input = true;
if (finished_input)
{
/// Close input if flag was set manually.
input.close();
/// Read from totals port if has it.
if (input.isFinished())
{
/// Read from totals port if has it.
if (inputs.size() > 1)
{
auto & totals_input = inputs.back();
@ -69,12 +71,8 @@ IAccumulatingTransform::Status IAccumulatingTransform::prepare()
totals_input.close();
}
}
}
/// Generate output block.
if (input.isFinished())
{
finished_input = true;
/// Generate output block.
return Status::Ready;
}