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

[CP] fix 1024_backup_restore_with_transfer_abort case issue

Browse Source
This commit is contained in:
oceanoverflow
2023-10-17 05:43:18 +00:00
committed by ob-robot
parent 5be7bb98ca
commit 3a8f5afb38
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/storage/ls/ob_ls_tablet_service.cpp
View File

@ -6091,6 +6091,7 @@ int ObLSTabletService::ha_scan_all_tablets(const HandleTabletMetaFunc &handle_ta
while (OB_SUCC(ret)) { while (OB_SUCC(ret)) {
tablet_info.reset(); tablet_info.reset();
user_data.reset();
committed_flag = false; committed_flag = false;
if (OB_FAIL(iterator.get_next_tablet(tablet_handle))) { if (OB_FAIL(iterator.get_next_tablet(tablet_handle))) {
if (OB_ITER_END == ret) { if (OB_ITER_END == ret) {
@ -6103,7 +6104,11 @@ int ObLSTabletService::ha_scan_all_tablets(const HandleTabletMetaFunc &handle_ta
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
LOG_WARN("tablet is nullptr", K(ret), K(tablet_handle)); LOG_WARN("tablet is nullptr", K(ret), K(tablet_handle));
} else if (OB_FAIL(tablet->ObITabletMdsInterface::get_latest_tablet_status(user_data, committed_flag))) { } else if (OB_FAIL(tablet->ObITabletMdsInterface::get_latest_tablet_status(user_data, committed_flag))) {
if (OB_EMPTY_RESULT == ret) {
ret = OB_SUCCESS;
} else {
LOG_WARN("failed to get latest tablet status", K(ret), KPC(tablet)); LOG_WARN("failed to get latest tablet status", K(ret), KPC(tablet));
}
} else if (!committed_flag && ObTabletStatus::TRANSFER_IN == user_data.tablet_status_) { } else if (!committed_flag && ObTabletStatus::TRANSFER_IN == user_data.tablet_status_) {
//TODO(muwei.ym) CAN NOT USE this condition when MDS supports uncommitted transaction //TODO(muwei.ym) CAN NOT USE this condition when MDS supports uncommitted transaction