thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-18 04:12:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

(fix) https://github.com/ClickHouse/ClickHouse/issues/66646 do not run executable table storage queries in single threaded pipeline executor

Browse Source
This commit is contained in:
yawnt 2024-09-27 19:40:51 +00:00
parent 07de943eca
commit 24c03a20e3
No known key found for this signature in database
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Processors/Sources/ShellCommandSource.cpp
View File

@ -667,7 +667,9 @@ Pipe ShellCommandSourceCoordinator::createPipe(
input_pipes[i].addTransform(std::move(transform));
}
auto num_streams = input_pipes[i].maxParallelStreams();
auto pipeline = std::make_shared<QueryPipeline>(std::move(input_pipes[i]));
pipeline->setNumThreads(num_streams);
auto out = context->getOutputFormat(configuration.format, *timeout_write_buffer, materializeBlock(pipeline->getHeader()));
out->setAutoFlush();
pipeline->complete(std::move(out));