Update max_threads for processors.

This commit is contained in:
Nikolai Kochetov 2019-08-30 17:21:22 +03:00
parent d6e13cbb92
commit 18fff141d1

View File

@ -1546,7 +1546,8 @@ void InterpreterSelectQuery::executeFetchColumns(
if constexpr (pipeline_with_processors) if constexpr (pipeline_with_processors)
{ {
pipeline.setMaxThreads(streams.size()); if (streams.size() == 1)
pipeline.setMaxThreads(streams.size());
/// Unify streams. They must have same headers. /// Unify streams. They must have same headers.
if (streams.size() > 1) if (streams.size() > 1)