Fix the memory leakage due to restoring session_info

2023-08-21 13:14:08 +00:00
parent 0e4a25ae34
commit 55caa9f69b
1 changed files with 3 additions and 0 deletions
--- a/src/sql/session/ob_basic_session_info.cpp
+++ b/src/sql/session/ob_basic_session_info.cpp
@ -5899,6 +5899,9 @@ int ObBasicSessionInfo::trans_restore_session(TransSavedValue &saved_value)
    LOG_WARN("failed to assign trans result", K(tmp_ret));
    ret = COVER_SUCC(tmp_ret);
  }
+  if (OB_NOT_NULL(tx_desc_)) {
+    MTL(transaction::ObTransService *)->release_tx(*tx_desc_);
+  }
  tx_desc_ = saved_value.tx_desc_;
  if (OB_TMP_FAIL(base_restore_session(saved_value))) {
    LOG_WARN("failed to restore base session", K(tmp_ret));