Update max_threads for processors.

This commit is contained in:
Nikolai Kochetov 2019-08-28 20:48:41 +03:00
parent ca232cebfb
commit d6e13cbb92

View File

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