Added force_add_agg_info to SourceFromInputStream/

This commit is contained in:
Nikolai Kochetov 2019-04-12 16:14:03 +03:00
parent 1e5731496c
commit 8298818036

View File

@ -33,7 +33,7 @@ Chunk SourceFromInputStream::generate()
UInt64 num_rows = block.rows();
Chunk chunk(block.getColumns(), num_rows);
if (has_aggregate_functions)
if (force_add_aggregating_info || has_aggregate_functions)
{
auto info = std::make_shared<AggregatedChunkInfo>();
info->bucket_num = block.info.bucket_num;