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

[CP] only NORMAL tablet can backup data

Browse Source
This commit is contained in:
wxhwang
2024-02-08 03:24:04 +00:00
committed by ob-robot
parent a73fbc69f4
commit dadec7a18a
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/storage/backup/ob_backup_utils.cpp
View File

@ -1902,6 +1902,7 @@ int ObBackupTabletProvider::get_tablet_handle_(const uint64_t tenant_id, const s
} else { } else {
// sync wait transfer in tablet replace table finish // sync wait transfer in tablet replace table finish
const int64_t ABS_TIMEOUT_TS = ObTimeUtil::current_time() + 5 * 60 * 1000 * 1000; //5min const int64_t ABS_TIMEOUT_TS = ObTimeUtil::current_time() + 5 * 60 * 1000 * 1000; //5min
bool is_normal_tablet = false;
while (OB_SUCC(ret)) { while (OB_SUCC(ret)) {
tablet_handle.reset(); tablet_handle.reset();
if (ABS_TIMEOUT_TS < ObTimeUtil::current_time()) { if (ABS_TIMEOUT_TS < ObTimeUtil::current_time()) {
@ -1919,6 +1920,11 @@ int ObBackupTabletProvider::get_tablet_handle_(const uint64_t tenant_id, const s
} else if (tablet_handle.get_obj()->get_tablet_meta().has_transfer_table()) { } else if (tablet_handle.get_obj()->get_tablet_meta().has_transfer_table()) {
LOG_INFO("transfer table is not replaced", K(ret), K(tenant_id), K(ls_id), K(tablet_id)); LOG_INFO("transfer table is not replaced", K(ret), K(tenant_id), K(ls_id), K(tablet_id));
usleep(100 * 1000); // wait 100ms usleep(100 * 1000); // wait 100ms
} else if (OB_FAIL(check_tablet_status_(tablet_handle, is_normal_tablet))) {
LOG_WARN("failed to check tablet is normal", K(ret), K(tenant_id), K(ls_id), K(rebuild_seq));
} else if (!is_normal_tablet) {
LOG_INFO("tablet status is not normal", K(tenant_id), K(ls_id), K(tablet_id));
usleep(100 * 1000); // wait 100ms
} else { } else {
break; break;
} }