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

Fix totals.

Browse Source
This commit is contained in:
Nikolai Kochetov 2019-04-17 17:56:46 +03:00
parent 323f742c1b
commit 87472146b3
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dbms/src/Interpreters/InterpreterSelectQuery.cpp
View File

@ -676,7 +676,7 @@ void InterpreterSelectQuery::executeImpl(TPipeline & pipeline, const BlockInputS
if (prepared_input)
{
if constexpr (pipeline_with_processors)
pipeline.init({std::make_shared<SourceFromInputStream>(std::make_shared<InputStreamHolder>(prepared_input))});
pipeline.init({std::make_shared<SourceFromInputStream>(prepared_input)});
else
pipeline.streams.push_back(prepared_input);
}
@ -778,8 +778,7 @@ void InterpreterSelectQuery::executeImpl(TPipeline & pipeline, const BlockInputS
if constexpr (pipeline_with_processors)
{
auto holder = std::make_shared<InputStreamHolder>(std::move(stream));
auto source = std::make_shared<SourceFromInputStream>(std::move(holder));
auto source = std::make_shared<SourceFromInputStream>(std::move(stream));
pipeline.addDelayedStream(source);
}
else