thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-25 11:10:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix rows_before_limit_at_least.

Browse Source
This commit is contained in:
Nikolai Kochetov 2019-05-13 15:08:02 +03:00
parent 73948ab747
commit fe9a45fee1
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
dbms/src/Processors/QueryPipeline.cpp
View File

@ -596,6 +596,16 @@ void QueryPipeline::calcRowsBeforeLimit()
continue;
}
/// Skip totals and extremes port for output format.
if (auto * format = typeid_cast<IOutputFormat *>(processor))
{
auto * child_processor = &format->getPort(IOutputFormat::PortKind::Main).getOutputPort().getProcessor();
if (visited.emplace(child_processor).second)
queue.push({ child_processor, visited_limit });
continue;
}
for (auto & child_port : processor->getInputs())
{
auto * child_processor = &child_port.getOutputPort().getProcessor();