diff options
| author | a-romanov <Anton.Romanov@ydb.tech> | 2023-10-19 12:07:07 +0300 |
|---|---|---|
| committer | a-romanov <Anton.Romanov@ydb.tech> | 2023-10-19 12:35:57 +0300 |
| commit | 71849fca8822e8ffce141da290c31b08eeaa23f1 (patch) | |
| tree | caa997fe721d9de9ceccc6d44a5298bb37e5c1d2 | |
| parent | a9cbadd19bda79fcf6cf76d91784baa0a24874bb (diff) | |
| download | ydb-71849fca8822e8ffce141da290c31b08eeaa23f1.tar.gz | |
YQL-16876 Copy constraints in case of trivial merge, more places.
| -rw-r--r-- | ydb/library/yql/providers/yt/provider/yql_yt_physical_optimize.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ydb/library/yql/providers/yt/provider/yql_yt_physical_optimize.cpp b/ydb/library/yql/providers/yt/provider/yql_yt_physical_optimize.cpp index 646ce88e13e..32c9ebfd4ea 100644 --- a/ydb/library/yql/providers/yt/provider/yql_yt_physical_optimize.cpp +++ b/ydb/library/yql/providers/yt/provider/yql_yt_physical_optimize.cpp @@ -3600,7 +3600,7 @@ private: *scheme, TYtSection(ctx.ChangeChild(section.Ref(), TYtSection::idx_Settings, std::move(settings))), {}, ctx, State_, - TCopyOrTrivialMapOpts().SetTryKeepSortness(keepSort).SetRangesResetSort(!keepSort).SetSectionUniq(section.Ref().GetConstraint<TDistinctConstraintNode>())); + TCopyOrTrivialMapOpts().SetTryKeepSortness(keepSort).SetRangesResetSort(!keepSort).SetSectionUniq(section.Ref().GetConstraint<TDistinctConstraintNode>()).SetConstraints(extend.Ref().GetConstraintSet())); updateChildren = true; newExtendParts.back() = allAreTableContents ? ctx.ChangeChild(child.Ref(), TYtTableContent::idx_Input, path.Table().Ptr()) @@ -3974,7 +3974,7 @@ private: .Settings(NYql::RemoveSettings(section.Settings().Ref(), EYtSettingType::DirectRead | EYtSettingType::Unordered | EYtSettingType::NonUnique, ctx)) .Done(), {}, ctx, State_, - TCopyOrTrivialMapOpts().SetTryKeepSortness(keepSorted).SetSectionUniq(section.Ref().GetConstraint<TDistinctConstraintNode>())); + TCopyOrTrivialMapOpts().SetTryKeepSortness(keepSorted).SetSectionUniq(section.Ref().GetConstraint<TDistinctConstraintNode>()).SetConstraints(read.Ref().GetConstraintSet())); auto newData = path.Columns().Maybe<TCoVoid>() && path.Ranges().Maybe<TCoVoid>() ? path.Table() |