thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-29 21:20:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix MutationsInterpreter.

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-09-16 11:58:27 +03:00
parent 13edfeea1f
commit a8e671f015
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Interpreters/MutationsInterpreter.cpp
View File

@ -724,9 +724,7 @@ void MutationsInterpreter::validate()
QueryPlan plan;
select_interpreter->buildQueryPlan(plan);
addStreamsForLaterStages(stages, plan);
auto pipeline = plan.buildQueryPipeline();
auto pipeline = addStreamsForLaterStages(stages, plan);
}
BlockInputStreamPtr MutationsInterpreter::execute()
@ -737,9 +735,7 @@ BlockInputStreamPtr MutationsInterpreter::execute()
QueryPlan plan;
select_interpreter->buildQueryPlan(plan);
addStreamsForLaterStages(stages, plan);
auto pipeline = plan.buildQueryPipeline();
auto pipeline = addStreamsForLaterStages(stages, plan);
BlockInputStreamPtr result_stream = std::make_shared<PipelineExecutingBlockInputStream>(std::move(*pipeline));
/// Sometimes we update just part of columns (for example UPDATE mutation)