From 049d3c411ae44e4443354838b175921b89c1e349 Mon Sep 17 00:00:00 2001 From: obdev Date: Mon, 12 Dec 2022 10:07:52 +0000 Subject: [PATCH] [CP] clear is_state_log_submitting flag after on_failure to make it be able to retry --- src/storage/tx/ob_trans_part_ctx.cpp | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/src/storage/tx/ob_trans_part_ctx.cpp b/src/storage/tx/ob_trans_part_ctx.cpp index c71a07181..8723c4986 100644 --- a/src/storage/tx/ob_trans_part_ctx.cpp +++ b/src/storage/tx/ob_trans_part_ctx.cpp @@ -2007,15 +2007,7 @@ int ObPartTransCtx::on_failure(ObTxLogCb *log_cb) ctx_tx_data_.set_start_log_ts(SCN()); } if (ObTxLogTypeChecker::is_state_log(log_type)) { - if (is_local_tx_()) { - if (ObTxLogType::TX_COMMIT_LOG == log_type) { - sub_state_.clear_state_log_submitting(); - } - } else { - if (ObTxLogType::TX_PREPARE_LOG == log_type) { - sub_state_.clear_state_log_submitting(); - } - } + sub_state_.clear_state_log_submitting(); } if (OB_FAIL(fix_redo_lsns_(log_cb))) { TRANS_LOG(ERROR, "fix redo lsns failed", KR(ret), K(*this));