thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-23 18:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
kssenii 2021-11-12 00:31:24 +03:00
parent e5b811f96d
commit f46569a46b
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/Storages/System/StorageSystemNumbers.cpp
View File

@ -149,7 +149,14 @@ Pipe StorageSystemNumbers::read(
UInt64 max_counter = offset + *limit;
for (size_t i = 0; i < num_streams; ++i)
pipe.addSource(std::make_shared<NumbersMultiThreadedSource>(state, max_block_size, max_counter));
{
auto source = std::make_shared<NumbersMultiThreadedSource>(state, max_block_size, max_counter);
if (i == 0)
source->addTotalRowsApprox(*limit);
pipe.addSource(std::move(source));
}
return pipe;
}