diff --git a/dbms/src/Interpreters/InterpreterSelectQuery.cpp b/dbms/src/Interpreters/InterpreterSelectQuery.cpp
index 100ee139bdd..7571b17a1bd 100644
--- a/dbms/src/Interpreters/InterpreterSelectQuery.cpp
+++ b/dbms/src/Interpreters/InterpreterSelectQuery.cpp
@@ -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));
             }