From 0ce9afd1e3ee53539267d9ce6893710e22ed9b46 Mon Sep 17 00:00:00 2001
From: Nikolai Kochetov <nik-kochetov@yandex-team.ru>
Date: Mon, 18 May 2020 19:19:43 +0300
Subject: [PATCH] Try fix tests.

---
 src/Processors/Executors/PipelineExecutingBlockInputStream.cpp | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/Processors/Executors/PipelineExecutingBlockInputStream.cpp b/src/Processors/Executors/PipelineExecutingBlockInputStream.cpp
index e7846f31bd5..75324cb25b8 100644
--- a/src/Processors/Executors/PipelineExecutingBlockInputStream.cpp
+++ b/src/Processors/Executors/PipelineExecutingBlockInputStream.cpp
@@ -31,6 +31,9 @@ void PipelineExecutingBlockInputStream::readPrefixImpl()
 
 Block PipelineExecutingBlockInputStream::readImpl()
 {
+    if (!executor)
+        executor = std::make_unique<PullingPipelineExecutor>(*pipeline);
+
     Block block;
     while (executor->pull(block))
     {