From 87472146b3a1ea5fd4d795a681ec9ba57d221f24 Mon Sep 17 00:00:00 2001
From: Nikolai Kochetov <nik-kochetov@yandex-team.ru>
Date: Wed, 17 Apr 2019 17:56:46 +0300
Subject: [PATCH] Fix totals.

---
 dbms/src/Interpreters/InterpreterSelectQuery.cpp | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/dbms/src/Interpreters/InterpreterSelectQuery.cpp b/dbms/src/Interpreters/InterpreterSelectQuery.cpp
index de7d11ccaf0..d23bbe99932 100644
--- a/dbms/src/Interpreters/InterpreterSelectQuery.cpp
+++ b/dbms/src/Interpreters/InterpreterSelectQuery.cpp
@@ -676,7 +676,7 @@ void InterpreterSelectQuery::executeImpl(TPipeline & pipeline, const BlockInputS
         if (prepared_input)
         {
             if constexpr (pipeline_with_processors)
-                pipeline.init({std::make_shared<SourceFromInputStream>(std::make_shared<InputStreamHolder>(prepared_input))});
+                pipeline.init({std::make_shared<SourceFromInputStream>(prepared_input)});
             else
                 pipeline.streams.push_back(prepared_input);
         }
@@ -778,8 +778,7 @@ void InterpreterSelectQuery::executeImpl(TPipeline & pipeline, const BlockInputS
 
                     if constexpr (pipeline_with_processors)
                     {
-                        auto holder = std::make_shared<InputStreamHolder>(std::move(stream));
-                        auto source = std::make_shared<SourceFromInputStream>(std::move(holder));
+                        auto source = std::make_shared<SourceFromInputStream>(std::move(stream));
                         pipeline.addDelayedStream(source);
                     }
                     else