thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-18 21:51:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix tests.

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-09-16 19:38:33 +03:00
parent 2f7ab2bca4
commit 73ad505735
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Processors/QueryPipeline.cpp
View File

@ -263,13 +263,13 @@ QueryPipeline QueryPipeline::unitePipelines(
} }
void QueryPipeline::addCreatingSetsTransform(SubqueryForSet subquery_for_set, const SizeLimits & limits, const Context & context) void QueryPipeline::addCreatingSetsTransform(const Block & res_header, SubqueryForSet subquery_for_set, const SizeLimits & limits, const Context & context)
{ {
resize(1); resize(1);
auto transform = std::make_shared<CreatingSetsTransform>( auto transform = std::make_shared<CreatingSetsTransform>(
pipeline.getHeader(), pipeline.getHeader(),
getOutputStream().header, res_header,
std::move(subquery_for_set), std::move(subquery_for_set),
limits, limits,
context)); context));

2
src/Processors/QueryPipeline.h
View File

@ -91,7 +91,7 @@ public:
/// Pipeline must have same header. /// Pipeline must have same header.
void addDelayingPipeline(QueryPipeline pipeline); void addDelayingPipeline(QueryPipeline pipeline);
void addCreatingSetsTransform(SubqueryForSet subquery_for_set, const SizeLimits & limits, const Context & context); void addCreatingSetsTransform(const Block & res_header, SubqueryForSet subquery_for_set, const SizeLimits & limits, const Context & context);
PipelineExecutorPtr execute(); PipelineExecutorPtr execute();

2
src/Processors/QueryPlan/CreatingSetsStep.cpp
View File

@ -39,7 +39,7 @@ CreatingSetStep::CreatingSetStep(
void CreatingSetStep::transformPipeline(QueryPipeline & pipeline) void CreatingSetStep::transformPipeline(QueryPipeline & pipeline)
{ {
pipeline.addCreatingSetsTransform(std::move(subquery_for_set), network_transfer_limits, context); pipeline.addCreatingSetsTransform(getOutputStream().header, std::move(subquery_for_set), network_transfer_limits, context);
} }
void CreatingSetStep::describeActions(FormatSettings & settings) const void CreatingSetStep::describeActions(FormatSettings & settings) const