diff --git a/src/storage/tx/ob_trans_define_v4.cpp b/src/storage/tx/ob_trans_define_v4.cpp index 35ba1fef4..3891354c8 100644 --- a/src/storage/tx/ob_trans_define_v4.cpp +++ b/src/storage/tx/ob_trans_define_v4.cpp @@ -861,6 +861,7 @@ void ObTxDesc::implicit_start_tx_() expire_ts_ = active_ts_ + timeout_us_; active_scn_ = get_tx_seq(); state_change_flags_.mark_all(); + TX_STAT_START_INC; } } diff --git a/src/storage/tx/ob_tx_api.cpp b/src/storage/tx/ob_tx_api.cpp index df6f34284..c0da64c40 100644 --- a/src/storage/tx/ob_tx_api.cpp +++ b/src/storage/tx/ob_tx_api.cpp @@ -286,8 +286,8 @@ int ObTransService::start_tx(ObTxDesc &tx, const ObTxParam &tx_param, const ObTr ret = OB_INVALID_ARGUMENT; TRANS_LOG(WARN, "invalid tx param", K(ret), KR(ret), K(tx_param)); } else { - TX_STAT_START_INC - ObSpinLockGuard guard(tx.lock_); + TX_STAT_START_INC; + ObSpinLockGuard guard(tx.lock_); tx.inc_op_sn(); if (!tx_id.is_valid()) { ret = tx_desc_mgr_.add(tx);