aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoraneporada <aneporada@yandex-team.com>2024-12-10 14:13:50 +0300
committeraneporada <aneporada@yandex-team.com>2024-12-10 14:34:20 +0300
commit73e8da4c3b3716355b13a2f70c9b3e6fc6513991 (patch)
tree8f10023837ed1ecbdffd9e14014847b353d0c92d
parentc255a91e6f0feaf9dc9a6a9b52d67ab18c43dae5 (diff)
downloadydb-73e8da4c3b3716355b13a2f70c9b3e6fc6513991.tar.gz
Fix mounts.txt. Improve diagnostics
commit_hash:3c3bc0fb4bcf949a90d2646b27f93b9ed580328d
-rw-r--r--yql/essentials/core/yql_aggregate_expander.cpp9
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;