Add check for empty proccessors in AggregatingTransform::expandPipeline

This commit is contained in:
filimonov 2022-06-29 15:23:53 +02:00 committed by GitHub
parent c5e0869c46
commit e0acb6e337
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -501,6 +501,8 @@ void AggregatingTransform::work()
Processors AggregatingTransform::expandPipeline()
{
if (processors.empty())
throw Exception("Can not expandPipeline in AggregatingTransform. This is a bug.", ErrorCodes::LOGICAL_ERROR);
auto & out = processors.back()->getOutputs().front();
inputs.emplace_back(out.getHeader(), this);
connect(out, inputs.back());