diff --git a/ydb/library/yql/core/yql_aggregate_expander.cpp b/ydb/library/yql/core/yql_aggregate_expander.cpp index d05c458d92ff..686dc75ffb19 100644 --- a/ydb/library/yql/core/yql_aggregate_expander.cpp +++ b/ydb/library/yql/core/yql_aggregate_expander.cpp @@ -1506,7 +1506,7 @@ TExprNode::TPtr TAggregateExpander::BuildFinalizeByKeyLambda(const TExprNode::TP .Seal() .Seal() .Build(); - if (AllowSpilling && !FinalColumnNames.empty()) { + if (AllowSpilling) { auto saveLambda = Ctx.Builder(Node->Pos()) .Lambda() .Param("key") @@ -2535,7 +2535,8 @@ TExprNode::TPtr TAggregateExpander::GeneratePostAggregateSerializePhase() { pickleType = KeyColumns->ChildrenSize() > 1 ? Ctx.MakeType(keyItemTypes) : keyItemTypes[0]; pickleTypeNode = ExpandType(Node->Pos(), *pickleType, Ctx); } - auto columnNames = FinalColumnNames; + bool aggregateOnly = (Suffix != ""); + const auto& columnNames = aggregateOnly ? FinalColumnNames : InitialColumnNames; return Ctx.Builder(Node->Pos()) .Lambda() .Param("key")