dbms: additions [#METR-17000].

This commit is contained in:
Alexey Milovidov 2015-12-06 21:55:09 +03:00
parent 513eb33b5b
commit 9ecd4a0fa2

View File

@ -847,6 +847,7 @@ Block Aggregator::convertOneBucketToBlock(
/** Для того, чтобы в случае исключения, агрегатор не уничтожал состояния агрегатных функций, владение которыми уже передано в block;
* А также для того, чтобы пораньше освободить память.
* TODO Правильно действовать в случае final.
*/
method.data.impls[bucket].clearAndShrink();
@ -1914,8 +1915,6 @@ std::unique_ptr<IBlockInputStream> Aggregator::mergeAndConvertToBlocks(ManyAggre
LOG_TRACE(log, "Merging aggregated data");
Stopwatch watch;
ManyAggregatedDataVariants non_empty_data;
non_empty_data.reserve(data_variants.size());
for (auto & data : data_variants)