replace ERROR log-level about do_xxx with WARN log-level

This commit is contained in:
obdev 2022-12-22 14:11:38 +00:00 committed by ob-robot
parent 46ed59f0a7
commit c004fed6a4
2 changed files with 3 additions and 3 deletions

View File

@ -289,14 +289,14 @@ int ObTxCycleTwoPhaseCommitter::continue_execution(const bool is_rollback)
} else {
if (is_rollback) {
if (OB_FAIL(drive_self_2pc_phase(ObTxState::ABORT))) {
TRANS_LOG(ERROR, "do abort failed", K(ret));
TRANS_LOG(WARN, "do abort failed", K(ret));
} else if (OB_TMP_FAIL(post_downstream_msg(ObTwoPhaseCommitMsgType::OB_MSG_TX_ABORT_REQ))) {
TRANS_LOG(WARN, "post abort request failed", K(tmp_ret), KPC(this));
}
} else {
// TODO, switch state first if do preapre can be executed repeatedly
if (OB_FAIL(drive_self_2pc_phase(ObTxState::PREPARE))) {
TRANS_LOG(ERROR, "do prepare failed", K(ret));
TRANS_LOG(WARN, "do prepare failed", K(ret));
} else if (OB_TMP_FAIL(post_downstream_msg(ObTwoPhaseCommitMsgType::OB_MSG_TX_PREPARE_REQ))) {
TRANS_LOG(WARN, "post prepare request failed", K(tmp_ret), KPC(this));
}

View File

@ -335,7 +335,7 @@ int ObTxCycleTwoPhaseCommitter::handle_2pc_prepare_request_impl_() {
} else if (OB_FAIL(apply_2pc_msg_(ObTwoPhaseCommitMsgType::OB_MSG_TX_PREPARE_REQ))) {
TRANS_LOG(WARN, "apply msg failed", K(ret), KPC(this));
} else if (OB_FAIL(drive_self_2pc_phase(ObTxState::PREPARE))) {
TRANS_LOG(ERROR, "do prepare failed", K(ret), K(*this));
TRANS_LOG(WARN, "do prepare failed", K(ret), K(*this));
} else {
switch (get_2pc_role()) {
case Ob2PCRole::ROOT: {