From 21e7c25134e20458ad83537b401229900b559dd1 Mon Sep 17 00:00:00 2001
From: alexey-milovidov <milovidov@yandex-team.ru>
Date: Tue, 23 Oct 2018 11:32:28 +0300
Subject: [PATCH] Update FinishSortingBlockInputStream.cpp

---
 dbms/src/DataStreams/FinishSortingBlockInputStream.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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;