diff options
| -rw-r--r-- | yql/essentials/core/yql_aggregate_expander.cpp | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/yql/essentials/core/yql_aggregate_expander.cpp b/yql/essentials/core/yql_aggregate_expander.cpp index e268d022e7..92258a3d6c 100644 --- a/yql/essentials/core/yql_aggregate_expander.cpp +++ b/yql/essentials/core/yql_aggregate_expander.cpp @@ -127,8 +127,9 @@ TExprNode::TPtr TAggregateExpander::ExpandAggApply(const TExprNode::TPtr& node) return ExpandPgAggregationTraits(node->Pos(), *aggDescPtr, false, node->ChildPtr(2), argTypes, itemType, Ctx); } - auto exportsPtr = TypesCtx.Modules->GetModule("/lib/yql/aggregate.yql"); - YQL_ENSURE(exportsPtr); + const TString modulePath = "/lib/yql/aggregate.yql"; + auto exportsPtr = TypesCtx.Modules->GetModule(modulePath); + YQL_ENSURE(exportsPtr, "Failed to get module " << modulePath); const auto& exports = exportsPtr->Symbols(); const auto ex = exports.find(TString(name) + "_traits_factory"); YQL_ENSURE(exports.cend() != ex); @@ -605,7 +606,7 @@ TExprNode::TPtr TAggregateExpander::MakeInputBlocks(const TExprNode::TPtr& strea TVector<TExprNode::TPtr> roots; for (ui32 i = 1; i < argsCount + 1; ++i) { auto root = trait->Child(2)->ChildPtr(i); - allTypes.push_back(root->GetTypeAnn()); + allTypes.push_back(root->GetTypeAnn()); auto status = RemapExpr(root, root, remaps, Ctx, TOptimizeExprSettings(&TypesCtx)); @@ -699,7 +700,7 @@ TExprNode::TPtr TAggregateExpander::TryGenerateBlockCombineAllOrHashed() { } else { stream = AggList; } - + TExprNode::TPtr blocks = MakeInputBlocks(stream, keyIdxs, outputColumns, aggs, false, false); if (!blocks) { return nullptr; |