From 9c5d555e6981afe8bbda6a1408e3ef16d5e9e9ed Mon Sep 17 00:00:00 2001
From: Nikolai Kochetov <nik-kochetov@yandex-team.ru>
Date: Fri, 12 Apr 2019 17:49:34 +0300
Subject: [PATCH] Fix limit transfrom prepare.

---
 dbms/src/Processors/LimitTransform.cpp | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)

diff --git a/dbms/src/Processors/LimitTransform.cpp b/dbms/src/Processors/LimitTransform.cpp
index 0244733f12e..a09ee58d648 100644
--- a/dbms/src/Processors/LimitTransform.cpp
+++ b/dbms/src/Processors/LimitTransform.cpp
@@ -120,13 +120,7 @@ LimitTransform::Status LimitTransform::prepare()
         output.push(std::move(current_chunk));
         has_block = false;
 
-        if (input.isFinished())
-        {
-            output.finish();
-            return Status::Finished;
-        }
-
-        return Status::NeedData;
+        return Status::PortFull;
     }
 
     /// No more data is needed.