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

set trans_mgr skip checksum when TxCtx recovery

Browse Source
This commit is contained in:
chinaxing
2024-04-16 17:46:00 +00:00
committed by ob-robot
parent 7a78d20312
commit 6ed4cef931
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/storage/tx/ob_trans_part_ctx.cpp
View File

@ -1610,7 +1610,8 @@ int ObPartTransCtx::recover_tx_ctx_table_info(ObTxCtxTableInfo &ctx_info)
// do nothing // do nothing
} else if (OB_FAIL(deep_copy_mds_array_(ctx_info.exec_info_.multi_data_source_, _unused_))) { } else if (OB_FAIL(deep_copy_mds_array_(ctx_info.exec_info_.multi_data_source_, _unused_))) {
TRANS_LOG(WARN, "deep copy ctx_info mds_array failed", K(ret)); TRANS_LOG(WARN, "deep copy ctx_info mds_array failed", K(ret));
} else if (OB_FAIL(mt_ctx_.update_checksum(exec_info_.checksum_, } else if (exec_info_.need_checksum_ &&
OB_FAIL(mt_ctx_.update_checksum(exec_info_.checksum_,
exec_info_.checksum_scn_))) { exec_info_.checksum_scn_))) {
TRANS_LOG(WARN, "recover checksum failed", K(ret), KPC(this), K(ctx_info)); TRANS_LOG(WARN, "recover checksum failed", K(ret), KPC(this), K(ctx_info));
} else if (!is_local_tx_() && OB_FAIL(ObTxCycleTwoPhaseCommitter::recover_from_tx_table())) { } else if (!is_local_tx_() && OB_FAIL(ObTxCycleTwoPhaseCommitter::recover_from_tx_table())) {
@ -1620,6 +1621,10 @@ int ObPartTransCtx::recover_tx_ctx_table_info(ObTxCtxTableInfo &ctx_info)
replay_completeness_.set(true); replay_completeness_.set(true);
} }
if (OB_SUCC(ret) && !exec_info_.need_checksum_) {
mt_ctx_.set_skip_checksum_calc();
}
if (OB_FAIL(ret)) { if (OB_FAIL(ret)) {
} else if (OB_FAIL(recover_ls_transfer_status_())) { } else if (OB_FAIL(recover_ls_transfer_status_())) {
TRANS_LOG(WARN, "recover ls transfer status failed", KR(ret)); TRANS_LOG(WARN, "recover ls transfer status failed", KR(ret));