thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-21 01:00:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix totals and extremes for delayed replica.

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-08-03 21:47:13 +03:00
parent 42c5248611
commit b6f04cac47
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Processors/Sources/DelayedSource.cpp
View File

@ -127,6 +127,9 @@ Processors DelayedSource::expandPipeline()
/// Add new inputs. They must have the same header as output.
for (const auto & output : {main_output, totals_output, extremes_output})
{
if (!output)
continue;
inputs.emplace_back(outputs.front().getHeader(), this);
/// Connect checks that header is same for ports.
connect(*output, inputs.back());