diff options
author | aneporada <aneporada@yandex-team.com> | 2025-03-25 22:54:03 +0300 |
---|---|---|
committer | aneporada <aneporada@yandex-team.com> | 2025-03-25 23:06:36 +0300 |
commit | de900c3367e4ffb43d51b072c370ee6413f93be9 (patch) | |
tree | 75581a7d9b311f2bfbcce6cc5b287c1f0e7608f6 | |
parent | 8c5737c8d393a14c8e82f80fdad4c5f3a2c0824a (diff) | |
download | ydb-de900c3367e4ffb43d51b072c370ee6413f93be9.tar.gz |
Revert SubstTable() removal from lookup join
Revert "Remove no longer needed SubstTables() usage"
This reverts commit 72811a87bb52cb9c55d482d56f7d5e9d73130c74, reversing
changes made to a83f53b96b5dae5ca0c80409e7e57cc35547ba5c.
commit_hash:a5a4cf22731853e378d7a6ddb61e674b898ef76a
-rw-r--r-- | yt/yql/providers/yt/provider/yql_yt_join_impl.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/yt/yql/providers/yt/provider/yql_yt_join_impl.cpp b/yt/yql/providers/yt/provider/yql_yt_join_impl.cpp index 6eea9754c91..f4942ab18d7 100644 --- a/yt/yql/providers/yt/provider/yql_yt_join_impl.cpp +++ b/yt/yql/providers/yt/provider/yql_yt_join_impl.cpp @@ -1838,6 +1838,11 @@ bool RewriteYtMapJoin(TYtEquiJoin equiJoin, const TJoinLabels& labels, bool isLo smallJoinMembers.push_back(smallMemberName); } + auto status = SubstTables(tableContent, state, false, ctx); + if (status.Level == IGraphTransformer::TStatus::Error) { + return false; + } + ctx.Step.Repeat(TExprStep::ExprEval); tableContent = ctx.Builder(pos) |