diff options
author | aneporada <aneporada@yandex-team.com> | 2024-12-10 14:13:50 +0300 |
---|---|---|
committer | aneporada <aneporada@yandex-team.com> | 2024-12-10 14:34:20 +0300 |
commit | 73e8da4c3b3716355b13a2f70c9b3e6fc6513991 (patch) | |
tree | 8f10023837ed1ecbdffd9e14014847b353d0c92d | |
parent | c255a91e6f0feaf9dc9a6a9b52d67ab18c43dae5 (diff) | |
download | ydb-73e8da4c3b3716355b13a2f70c9b3e6fc6513991.tar.gz |
Fix mounts.txt. Improve diagnostics
commit_hash:3c3bc0fb4bcf949a90d2646b27f93b9ed580328d
-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; |