diff options
author | udovichenko-r <rvu@ydb.tech> | 2023-10-03 15:08:21 +0300 |
---|---|---|
committer | udovichenko-r <rvu@ydb.tech> | 2023-10-03 16:43:33 +0300 |
commit | 38a69849380d7d1b8c707dc4252723f3a5e7fee1 (patch) | |
tree | a6fa4e80f0e53305f4e4cd1a3944161a553835a9 | |
parent | f847a2d778260a7998d5bf7fb77709eb3060e2bc (diff) | |
download | ydb-38a69849380d7d1b8c707dc4252723f3a5e7fee1.tar.gz |
[hybrid] Use original world dependencies in empty join
YQL-16546
-rw-r--r-- | ydb/library/yql/providers/yt/provider/yql_yt_join_impl.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ydb/library/yql/providers/yt/provider/yql_yt_join_impl.cpp b/ydb/library/yql/providers/yt/provider/yql_yt_join_impl.cpp index 6aac7d05941..2447f1a9f6a 100644 --- a/ydb/library/yql/providers/yt/provider/yql_yt_join_impl.cpp +++ b/ydb/library/yql/providers/yt/provider/yql_yt_join_impl.cpp @@ -2739,12 +2739,12 @@ bool RewriteYtEmptyJoin(TYtEquiJoin equiJoin, const TJoinLabels& labels, TYtJoin TSyncMap syncList; for (auto path: leftLeaf.Section.Paths()) { if (auto out = path.Table().Maybe<TYtOutput>()) { - syncList.emplace(GetOutputOp(out.Cast()).Ptr(), syncList.size()); + syncList.emplace(out.Cast().Operation().Ptr(), syncList.size()); } } for (auto path: rightLeaf.Section.Paths()) { if (auto out = path.Table().Maybe<TYtOutput>()) { - syncList.emplace(GetOutputOp(out.Cast()).Ptr(), syncList.size()); + syncList.emplace(out.Cast().Operation().Ptr(), syncList.size()); } } |