From 82988180365cd561cee986dd7e5536e2b3145fd3 Mon Sep 17 00:00:00 2001
From: Nikolai Kochetov <nik-kochetov@yandex-team.ru>
Date: Fri, 12 Apr 2019 16:14:03 +0300
Subject: [PATCH] Added force_add_agg_info to SourceFromInputStream/

---
 dbms/src/Processors/Sources/SourceFromInputStream.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/dbms/src/Processors/Sources/SourceFromInputStream.cpp b/dbms/src/Processors/Sources/SourceFromInputStream.cpp
index 230681e1370..606323605ca 100644
--- a/dbms/src/Processors/Sources/SourceFromInputStream.cpp
+++ b/dbms/src/Processors/Sources/SourceFromInputStream.cpp
@@ -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;