aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorudovichenko-r <rvu@ydb.tech>2023-10-03 15:08:21 +0300
committerudovichenko-r <rvu@ydb.tech>2023-10-03 16:43:33 +0300
commit38a69849380d7d1b8c707dc4252723f3a5e7fee1 (patch)
treea6fa4e80f0e53305f4e4cd1a3944161a553835a9
parentf847a2d778260a7998d5bf7fb77709eb3060e2bc (diff)
downloadydb-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.cpp4
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());
}
}