diff --git a/dbms/src/Storages/MergeTree/MergeTreeBaseBlockInputStream.cpp b/dbms/src/Storages/MergeTree/MergeTreeBaseBlockInputStream.cpp index fa34480bbb4..216b3ea2994 100644 --- a/dbms/src/Storages/MergeTree/MergeTreeBaseBlockInputStream.cpp +++ b/dbms/src/Storages/MergeTree/MergeTreeBaseBlockInputStream.cpp @@ -84,7 +84,7 @@ Block MergeTreeBaseBlockInputStream::readFromPart() MergeTreeReadTask & task, MergeTreeRangeReader & reader) { if (!task.size_predictor) - return max_block_size_rows; + return std::max(1, max_block_size_rows); size_t rows_to_read_for_block = task.size_predictor->estimateNumRows(preferred_block_size_bytes); size_t rows_to_read_for_max_size_column