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

fix setNeeded() in PlanSquashing

Browse Source
This commit is contained in:
yariks5s 2024-06-13 14:52:34 +00:00
parent 4a72b36f28
commit c5159bc3aa
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/Processors/Transforms/PlanSquashingTransform.cpp
View File

@ -64,12 +64,12 @@ IProcessor::Status PlanSquashingTransform::prepareConsume()
for (auto & input : inputs) for (auto & input : inputs)
{ {
if (!input.isFinished()) if (!input.isFinished())
all_finished = false;
else
{ {
all_finished = false;
input.setNeeded(); input.setNeeded();
continue;
} }
else
continue;
if (input.hasData()) if (input.hasData())
{ {