@@ -127,8 +127,9 @@ TExprNode::TPtr TAggregateExpander::ExpandAggApply(const TExprNode::TPtr& node)
127
127
return ExpandPgAggregationTraits (node->Pos (), *aggDescPtr, false , node->ChildPtr (2 ), argTypes, itemType, Ctx);
128
128
}
129
129
130
- auto exportsPtr = TypesCtx.Modules ->GetModule (" /lib/yql/aggregate.yql" );
131
- YQL_ENSURE (exportsPtr);
130
+ const TString modulePath = " /lib/yql/aggregate.yql" ;
131
+ auto exportsPtr = TypesCtx.Modules ->GetModule (modulePath);
132
+ YQL_ENSURE (exportsPtr, " Failed to get module " << modulePath);
132
133
const auto & exports = exportsPtr->Symbols ();
133
134
const auto ex = exports.find (TString (name) + " _traits_factory" );
134
135
YQL_ENSURE (exports.cend () != ex);
@@ -605,7 +606,7 @@ TExprNode::TPtr TAggregateExpander::MakeInputBlocks(const TExprNode::TPtr& strea
605
606
TVector<TExprNode::TPtr> roots;
606
607
for (ui32 i = 1 ; i < argsCount + 1 ; ++i) {
607
608
auto root = trait->Child (2 )->ChildPtr (i);
608
- allTypes.push_back (root->GetTypeAnn ());
609
+ allTypes.push_back (root->GetTypeAnn ());
609
610
610
611
auto status = RemapExpr (root, root, remaps, Ctx, TOptimizeExprSettings (&TypesCtx));
611
612
@@ -699,7 +700,7 @@ TExprNode::TPtr TAggregateExpander::TryGenerateBlockCombineAllOrHashed() {
699
700
} else {
700
701
stream = AggList;
701
702
}
702
-
703
+
703
704
TExprNode::TPtr blocks = MakeInputBlocks (stream, keyIdxs, outputColumns, aggs, false , false );
704
705
if (!blocks) {
705
706
return nullptr ;
0 commit comments