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))
     {