aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authora-romanov <Anton.Romanov@ydb.tech>2023-10-27 11:25:04 +0300
committera-romanov <Anton.Romanov@ydb.tech>2023-10-27 11:54:41 +0300
commitb15f8132b6d2f5cde633d1207654042993d93bb8 (patch)
treeb84be084a7858f18565abad115dc54f523db8891
parent9f0d269f99492ad31a0882ded8db0547a5d92fad (diff)
downloadydb-b15f8132b6d2f5cde633d1207654042993d93bb8.tar.gz
YQL-16757 Fix cleanup temporary key.
-rw-r--r--ydb/library/yql/minikql/comp_nodes/mkql_map_join.cpp10
1 files changed, 3 insertions, 7 deletions
diff --git a/ydb/library/yql/minikql/comp_nodes/mkql_map_join.cpp b/ydb/library/yql/minikql/comp_nodes/mkql_map_join.cpp
index a6a5723f63..4b000dd8df 100644
--- a/ydb/library/yql/minikql/comp_nodes/mkql_map_join.cpp
+++ b/ydb/library/yql/minikql/comp_nodes/mkql_map_join.cpp
@@ -350,7 +350,7 @@ public:
if constexpr (WithoutRight) {
this->GenFillLeftStruct(current.second, getters);
- if (RightRequired) {
+ if constexpr (RightRequired) {
BranchInst::Create(loop, step, none, block);
} else {
result->addIncoming(ConstantInt::get(resultType, i32(EFetchResult::One)), block);
@@ -362,9 +362,7 @@ public:
const auto cont = CallBoxedValueVirtualMethod<NUdf::TBoxedValueAccessor::EMethod::Contains>(Type::getInt1Ty(context), dict, ctx.Codegen, block, keysPtr);
if constexpr (!IsTuple) {
- if (this->IsUnusedInput(this->LeftKeyColumns.front())) {
- ValueCleanup(GetValueRepresentation(this->DictType->GetKeyType()), keysPtr, ctx, block);
- }
+ ValueCleanup(GetValueRepresentation(this->DictType->GetKeyType()), keysPtr, ctx, block);
}
result->addIncoming(ConstantInt::get(resultType, i32(EFetchResult::One)), block);
@@ -392,9 +390,7 @@ public:
const auto lookup = new LoadInst(valueType, lookupPtr, "lookup", block);
if constexpr (!IsTuple) {
- if (this->IsUnusedInput(this->LeftKeyColumns.front())) {
- ValueCleanup(GetValueRepresentation(this->DictType->GetKeyType()), keysPtr, ctx, block);
- }
+ ValueCleanup(GetValueRepresentation(this->DictType->GetKeyType()), keysPtr, ctx, block);
}
const auto ok = CmpInst::Create(Instruction::ICmp, ICmpInst::ICMP_NE, lookup, zero, "ok", block);