aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoruzhas <uzhas@ydb.tech>2022-09-09 15:22:32 +0300
committeruzhas <uzhas@ydb.tech>2022-09-09 15:22:32 +0300
commit42578558983241f5b879a6453387a47c4ada2d27 (patch)
tree40e68a0282698819660515babe1cff1260563275
parent7dbd7a386cada4de30e2313e53e164aa48121340 (diff)
downloadydb-42578558983241f5b879a6453387a47c4ada2d27.tar.gz
,s3: fix extract members
-rw-r--r--ydb/library/yql/providers/s3/provider/yql_s3_logical_opt.cpp3
1 files changed, 2 insertions, 1 deletions
diff --git a/ydb/library/yql/providers/s3/provider/yql_s3_logical_opt.cpp b/ydb/library/yql/providers/s3/provider/yql_s3_logical_opt.cpp
index e41a804261..015254f159 100644
--- a/ydb/library/yql/providers/s3/provider/yql_s3_logical_opt.cpp
+++ b/ydb/library/yql/providers/s3/provider/yql_s3_logical_opt.cpp
@@ -441,7 +441,8 @@ public:
}
newPaths = ctx.ChangeChildren(maybeS3SourceSettings.Cast().Paths().Ref(), std::move(newPathItems));
- TExprNode::TPtr newExtra = ctx.ChangeChildren(*originalExtra, std::move(newExtraColumnsExtents));
+
+ TExprNode::TPtr newExtra = ctx.NewCallable(extraColumnsSetting->Pos(), "OrderedExtend", std::move(newExtraColumnsExtents));
newSettings = TExprBase(extraTypeItems.empty() ? RemoveSetting(settings.Cast().Ref(), "extraColumns", ctx) :
ReplaceSetting(settings.Cast().Ref(), extraColumnsSetting->Pos(), "extraColumns", newExtra, ctx));
}