From 574721186489fea67f4bc2e00061678eda0bec92 Mon Sep 17 00:00:00 2001 From: felix-w15 <806547150@qq.com> Date: Thu, 4 Jul 2024 04:49:02 +0000 Subject: [PATCH] tx desc start session id bug fix --- src/storage/tx/ob_tx_free_route.cpp | 1 + 1 file changed, 1 insertion(+) diff --git a/src/storage/tx/ob_tx_free_route.cpp b/src/storage/tx/ob_tx_free_route.cpp index 09f1d50f37..c9abd513e0 100644 --- a/src/storage/tx/ob_tx_free_route.cpp +++ b/src/storage/tx/ob_tx_free_route.cpp @@ -718,6 +718,7 @@ int ObTransService::txn_free_route__update_extra_state(const uint32_t session_id } else if ((add_tx || replace_tx) && OB_FAIL(tx_desc_mgr_.add_with_txid(tx->tx_id_, *tx))) { TRANS_LOG(WARN, "add tx to mgr fail", K(ret)); } else if (FALSE_IT(tx->flags_.REPLICA_ = tx->addr_ != self_)) { + } else if (FALSE_IT(ctx.set_start_sessid(tx->sess_id_))) { } int64_t elapsed_us = ObTimeUtility::current_time() - start_ts; ObTransTraceLog &tlog = tx->get_tlog();