Merge pull request #39601 from ClickHouse/fix-chain-add-sink

Fix Chain::addSink
This commit is contained in:
Nikolai Kochetov 2022-07-26 14:54:44 +02:00 committed by GitHub
commit 908c1d8cba
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -96,7 +96,7 @@ void Chain::addSink(ProcessorPtr processor)
if (!processors.empty())
connect(getOutputPort(), processor->getInputs().front());
processors.emplace_front(std::move(processor));
processors.emplace_back(std::move(processor));
}
IProcessor & Chain::getSource()