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

Fix get rows before limit at least.

Browse Source
This commit is contained in:
Nikolai Kochetov 2019-04-12 18:20:24 +03:00
parent e7799aafcf
commit bcf3534e35
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

@ -503,6 +503,16 @@ void QueryPipeline::calcRowsBeforeLimit()
has_limit = true;
rows_before_limit_at_least += limit->getRowsBeforeLimitAtLeast();
}
if (auto * source = typeid_cast<SourceFromInputStream *>(processor.get()))
{
auto & info = source->getStream().getProfileInfo();
if (info.hasAppliedLimit())
{
has_limit = true;
rows_before_limit_at_least += info.getRowsBeforeLimit();
}
}
}
UInt64 rows_before_limit = 0;