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

Fix StrictResize processor.

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-01-17 20:04:37 +03:00
parent 7803e518c6
commit 61594edcee
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dbms/src/Processors/ResizeProcessor.cpp
View File

@ -316,6 +316,8 @@ IProcessor::Status StrictResizeProcessor::prepare(const PortNumbers & updated_in
{
input.status = InputStatus::Finished;
++num_finished_inputs;
waiting_outputs.push(input.waiting_output);
}
continue;
}