From 92bc2701cd8751a27d15512b50f488c1de31bd9c Mon Sep 17 00:00:00 2001
From: GongYusen <986957406@qq.com>
Date: Wed, 1 Jan 2025 09:15:11 +0000
Subject: [PATCH] fix unfree ptr in MergeJoinOperator

---
 src/sql/engine/join/ob_merge_join_vec_op.cpp | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/src/sql/engine/join/ob_merge_join_vec_op.cpp b/src/sql/engine/join/ob_merge_join_vec_op.cpp
index 5ca39fb7d..ff5038652 100644
--- a/src/sql/engine/join/ob_merge_join_vec_op.cpp
+++ b/src/sql/engine/join/ob_merge_join_vec_op.cpp
@@ -1280,10 +1280,9 @@ int ObMergeJoinVecOp::inner_open() {
                                       right_match_cursor_))) {
         ret = OB_ALLOCATE_MEMORY_FAILED;
         LOG_WARN("alloc ObSemiAntiJoinTracker failed", K(ret));
+      } else if (OB_FALSE_IT(tracker_ = tracker)) {
       } else if (OB_FAIL(tracker->init(tenant_id, MY_SPEC.max_batch_size_))) {
         LOG_WARN("ObSemiAntiJoinTracker init failed", K(ret));
-      } else {
-        tracker_ = tracker;
       }
     } else {
       bool need_trace = join_type != INNER_JOIN && MY_SPEC.other_join_conds_.count() != 0;
@@ -1295,10 +1294,9 @@ int ObMergeJoinVecOp::inner_open() {
                                       right_match_cursor_))) {
         ret = OB_ALLOCATE_MEMORY_FAILED;
         LOG_WARN("alloc ObCommonJoinTracker failed", K(ret));
+      } else if (OB_FALSE_IT(tracker_ = tracker)) {
       } else if (OB_FAIL(tracker->init(MY_SPEC.max_batch_size_))) {
         LOG_WARN("ObCommonJoinTracker init failed", K(ret));
-      } else {
-        tracker_ = tracker;
       }
     }
     LOG_TRACE("trace init sql mem mgr for merge join",