diff --git a/src/Processors/QueryPlan/ReadFromSystemNumbersStep.cpp b/src/Processors/QueryPlan/ReadFromSystemNumbersStep.cpp
index 67c228d43f4..da8a6933d6f 100644
--- a/src/Processors/QueryPlan/ReadFromSystemNumbersStep.cpp
+++ b/src/Processors/QueryPlan/ReadFromSystemNumbersStep.cpp
@@ -582,6 +582,10 @@ Pipe ReadFromSystemNumbersStep::makePipe()
     const auto step_between_chunks = num_streams * block_range;
     for (size_t i = 0; i < num_streams; ++i)
     {
+        const auto source_start = numbers_storage.offset + i * block_range;
+        if (numbers_storage.limit.has_value() && *numbers_storage.limit < source_start)
+            break;
+
         auto source = std::make_shared<NumbersSource>(
             max_block_size,
             numbers_storage.offset + i * block_range,