Added force_add_agg_info to SourceFromInputStream/

This commit is contained in:
Nikolai Kochetov 2019-04-12 16:16:07 +03:00
parent 8298818036
commit 6949f2d80a

View File

@ -1329,7 +1329,7 @@ void InterpreterSelectQuery::executeFetchColumns(
{
auto holder = std::make_shared<InputStreamHolder>(stream);
bool force_add_agg_info = processing_stage == QueryProcessingStage::WithMergeableState;
sources.emplace_back(std::make_shared<SourceFromInputStream>(holder), force_add_agg_info);
sources.emplace_back(std::make_shared<SourceFromInputStream>(holder, force_add_agg_info));
holders.emplace_back(std::move(holder));
}