aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorudovichenko-r <udovichenko-r@yandex-team.com>2025-02-10 20:03:39 +0300
committerudovichenko-r <udovichenko-r@yandex-team.com>2025-02-10 22:09:07 +0300
commit7743bf2e4f41f9d4220fbab577bb1257f19d57d3 (patch)
treeef65171ec0f6c2875474fc2f7da71a9212dbb05e
parent00686935834f8dddef76e9d12d0ff6a17455b5cf (diff)
downloadydb-7743bf2e4f41f9d4220fbab577bb1257f19d57d3.tar.gz
Fix PhysicalOptimizer-MultiReduceFieldsSubset
commit_hash:1e34b093f0bfce863588a645b6324aa5a8d966cd
-rw-r--r--yt/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt_field_subset.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/yt/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt_field_subset.cpp b/yt/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt_field_subset.cpp
index a2f5fd4100..5f5ed8238c 100644
--- a/yt/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt_field_subset.cpp
+++ b/yt/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt_field_subset.cpp
@@ -99,14 +99,14 @@ TMaybeNode<TExprBase> TYtPhysicalOptProposalTransformer::LambdaVisitFieldsSubset
auto itemType = visitLambda->Head().Head().GetTypeAnn()->Cast<TStructExprType>();
auto reduceBy = NYql::GetSettingAsColumnList(op.Settings().Ref(), EYtSettingType::ReduceBy);
for (auto& col: reduceBy) {
- if (auto type = itemType->FindItemType(col)) {
- memberSet.insert(type->Cast<TItemExprType>()->GetName());
+ if (itemType->FindItem(col)) {
+ memberSet.insert(col);
}
}
auto sortBy = NYql::GetSettingAsColumnList(op.Settings().Ref(), EYtSettingType::SortBy);
for (auto& col: sortBy) {
- if (auto type = itemType->FindItemType(col)) {
- memberSet.insert(type->Cast<TItemExprType>()->GetName());
+ if (itemType->FindItem(col)) {
+ memberSet.insert(col);
}
}