Do not create processors for totals stream.

This commit is contained in:
Nikolai Kochetov 2019-04-30 20:12:43 +03:00
parent 1410d1a1ae
commit ad8af5b5ba

View File

@ -137,10 +137,14 @@ void QueryPipeline::addSimpleTransformImpl(const TProcessorGetter & getter)
auto & out_header = transform ? transform->getOutputs().front().getHeader()
: stream->getHeader();
if (header)
assertBlocksHaveEqualStructure(header, out_header, "QueryPipeline");
else
header = out_header;
if (stream_type != StreamType::Totals)
{
if (header)
assertBlocksHaveEqualStructure(header, out_header, "QueryPipeline");
else
header = out_header;
}
if (transform)
{