Do not create processors for totals stream.

This commit is contained in:
Nikolai Kochetov 2019-04-30 20:20:34 +03:00
parent ad8af5b5ba
commit f170e55ebd

View File

@ -718,8 +718,11 @@ void InterpreterSelectQuery::executeImpl(TPipeline & pipeline, const BlockInputS
{ {
if constexpr (pipeline_with_processors) if constexpr (pipeline_with_processors)
{ {
pipeline.addSimpleTransform([&](const Block & block) pipeline.addSimpleTransform([&](const Block & block, QueryPipeline::StreamType stream_type) -> ProcessorPtr
{ {
if (stream_type == QueryPipeline::StreamType::Totals)
return nullptr;
return std::make_shared<FilterTransform>( return std::make_shared<FilterTransform>(
block, block,
expressions.filter_info->actions, expressions.filter_info->actions,