diff --git a/dbms/src/DataStreams/FinishSortingBlockInputStream.cpp b/dbms/src/DataStreams/FinishSortingBlockInputStream.cpp
index 7a16737f928..015ea8bf903 100644
--- a/dbms/src/DataStreams/FinishSortingBlockInputStream.cpp
+++ b/dbms/src/DataStreams/FinishSortingBlockInputStream.cpp
@@ -64,7 +64,7 @@ struct Less
 
 Block FinishSortingBlockInputStream::readImpl()
 {
-    if (limit && total_rows_processed == limit)
+    if (limit && total_rows_processed >= limit)
         return {};
 
     Block res;