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

Repair -4016 error that occur in start_scn invalid

Browse Source
This commit is contained in:
obdev
2024-02-08 21:38:04 +00:00
committed by ob-robot
parent 012fce842f
commit 337cddce15
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/storage/high_availability/ob_finish_transfer.cpp
View File

@ -1057,8 +1057,8 @@ int ObTxFinishTransfer::record_server_event_(
ObSqlString extra_info_str; ObSqlString extra_info_str;
const share::ObTransferStatus doing_status(ObTransferStatus::DOING); const share::ObTransferStatus doing_status(ObTransferStatus::DOING);
const share::ObTransferStatus finish_status(ObTransferStatus::COMPLETED); const share::ObTransferStatus finish_status(ObTransferStatus::COMPLETED);
const int64_t start_scn_ts = start_scn.convert_to_ts(); const int64_t start_scn_ts = start_scn.is_valid() ? start_scn.convert_to_ts() : 0;
const int64_t elapsed_us_from_start_scn = ObTimeUtility::current_time() - start_scn_ts; const int64_t elapsed_us_from_start_scn = start_scn.is_valid() ? ObTimeUtility::current_time() - start_scn_ts : 0;
if (OB_SUCCESS == result) { if (OB_SUCCESS == result) {
if (is_ready) { if (is_ready) {
if (OB_FAIL(extra_info_str.append_fmt("msg:\"transfer doing success\";"))) { if (OB_FAIL(extra_info_str.append_fmt("msg:\"transfer doing success\";"))) {
@ -1073,7 +1073,7 @@ int ObTxFinishTransfer::record_server_event_(
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
if (OB_FAIL(extra_info_str.append_fmt("round:%ld;", round))) { if (OB_FAIL(extra_info_str.append_fmt("round:%ld;", round))) {
LOG_WARN("fail to printf retry time", K(ret)); LOG_WARN("fail to printf retry time", K(ret));
} else if (OB_FAIL(extra_info_str.append_fmt("elapsed_us_from_start_scn:%ld;", elapsed_us_from_start_scn))) { } else if (elapsed_us_from_start_scn > 0 && OB_FAIL(extra_info_str.append_fmt("elapsed_us_from_start_scn:%ld;", elapsed_us_from_start_scn))) {
LOG_WARN("fail to printf retry time", K(ret)); LOG_WARN("fail to printf retry time", K(ret));
} else { } else {
if (OB_SUCCESS == result && is_ready) { if (OB_SUCCESS == result && is_ready) {