From 72fea5bf9791aa8052565912d095c666548f09b9 Mon Sep 17 00:00:00 2001
From: Nikolai Kochetov <nik-kochetov@yandex-team.ru>
Date: Tue, 10 Sep 2019 11:50:31 +0300
Subject: [PATCH] Added ThreadsQueue to PipelineExecutor.

---
 dbms/src/Processors/Executors/PipelineExecutor.cpp | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/dbms/src/Processors/Executors/PipelineExecutor.cpp b/dbms/src/Processors/Executors/PipelineExecutor.cpp
index 2293e507250..183ce194396 100644
--- a/dbms/src/Processors/Executors/PipelineExecutor.cpp
+++ b/dbms/src/Processors/Executors/PipelineExecutor.cpp
@@ -661,6 +661,8 @@ void PipelineExecutor::executeImpl(size_t num_threads)
 {
     Stack stack;
 
+    threads_queue.init(num_threads);
+
     executor_contexts.reserve(num_threads);
     for (size_t i = 0; i < num_threads; ++i)
         executor_contexts.emplace_back(std::make_unique<ExecutorContext>());