try fix tests.

This commit is contained in:
Nikolai Kochetov 2020-05-28 19:01:12 +03:00
parent ea3f638b30
commit 534e55f5b5

View File

@ -996,13 +996,10 @@ void InterpreterSelectQuery::executeFetchColumns(
argument_types[j] = header.getByName(desc->argument_names[j]).type; argument_types[j] = header.getByName(desc->argument_names[j]).type;
Block block_with_count{ Block block_with_count{
{ColumnPtr(column->cloneEmpty()), std::make_shared<DataTypeAggregateFunction>(func, argument_types, desc->parameters), desc->column_name}}; {std::move(column), std::make_shared<DataTypeAggregateFunction>(func, argument_types, desc->parameters), desc->column_name}};
Chunk chunk(Columns(), column->size()); auto istream = std::make_shared<OneBlockInputStream>(block_with_count);
chunk.addColumn(std::move(column)); pipeline.init(Pipe(std::make_shared<SourceFromInputStream>(istream)));
auto source = std::make_shared<SourceFromSingleChunk>(std::move(block_with_count), std::move(chunk));
pipeline.init(Pipe(std::move(source)));
from_stage = QueryProcessingStage::WithMergeableState; from_stage = QueryProcessingStage::WithMergeableState;
analysis_result.first_stage = false; analysis_result.first_stage = false;
return; return;