hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix compat bug about 2pc from 4.0 to 4.1

Browse Source
This commit is contained in:
obdev 2023-03-07 05:41:10 +00:00 committed by ob-robot
parent 8c423e7ff3
commit 851f6655e8
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/storage/tx/ob_tx_2pc_msg_handler.cpp
View File

@ -586,8 +586,9 @@ int ObPartTransCtx::apply_2pc_msg_(const ObTwoPhaseCommitMsgType msg_type)
}
case ObTwoPhaseCommitMsgType::OB_MSG_TX_CLEAR_REQ: {
const Ob2pcClearReqMsg &msg = *(static_cast<const Ob2pcClearReqMsg *>(msg_2pc_cache_));
if (msg.max_commit_log_scn_ < max_2pc_commit_scn_
|| msg.max_commit_log_scn_ < ctx_tx_data_.get_end_log_ts()) {
if (CLUSTER_VERSION_4_1_0_0 <= GET_MIN_CLUSTER_VERSION()
&& (msg.max_commit_log_scn_ < max_2pc_commit_scn_
|| msg.max_commit_log_scn_ < ctx_tx_data_.get_end_log_ts())) {
ret = OB_ERR_UNEXPECTED;
TRANS_LOG(WARN, "unexpected max commit log scn in clear request", K(ret), KPC(this));
} else {