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

[CP] fix restart failed during tenant restore

Browse Source
This commit is contained in:
wxhwang
2024-02-06 23:16:41 +00:00
committed by ob-robot
parent c7ee677377
commit 199ee4d183
6 changed files with 10 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/storage/high_availability/ob_ls_complete_migration.cpp
View File

@ -1573,7 +1573,7 @@ int ObStartCompleteMigrationTask::check_need_wait_transfer_table_replace_(
LOG_WARN("check need wait log sync get invalid argument", K(ret), KP(ls));
} else if (OB_FAIL(ls->get_restore_status(ls_restore_status))) {
LOG_WARN("failed to get restore status", K(ret), KPC(ctx_));
} else if (ls_restore_status.is_in_restore_and_before_quick_restore()) {
} else if (ls_restore_status.is_before_restore_to_consistent_scn()) {
need_wait = false;
}
return ret;

4
src/storage/restore/ob_ls_restore_handler.cpp
View File

@ -2166,10 +2166,6 @@ int ObLSRestoreConsistentScnState::set_empty_for_transfer_tablets_()
LOG_WARN("failed to get tablet status", K(ret), KPC(tablet));
} else if (!is_commited && ObTabletStatus::TRANSFER_IN == user_data.tablet_status_.get_status()) {
LOG_INFO("skip tablet which transfer in not commit", "tablet_id", tablet->get_tablet_meta().tablet_id_, K(user_data));
} else if (!tablet->get_tablet_meta().ha_status_.is_restore_status_full()) {
LOG_INFO("skip tablet which restore status is not full",
"tablet_id", tablet->get_tablet_meta().tablet_id_,
"ha_status", tablet->get_tablet_meta().ha_status_);
} else if (OB_FAIL(ls_->update_tablet_restore_status(tablet->get_tablet_meta().tablet_id_,
restore_status,
true/* need reset tranfser flag */))) {

6
src/storage/slog_ckpt/ob_tablet_replay_create_handler.cpp
View File

@ -534,9 +534,9 @@ int ObTabletReplayCreateHandler::record_ls_transfer_info_(
LOG_INFO("The log stream does not need to record transfer_info", "ls_id", ls->get_ls_id(), K(current_migration_status), K(new_migration_status));
} else if (OB_FAIL(ls->get_restore_status(ls_restore_status))) {
LOG_WARN("failed to get ls restore status", K(ret), KPC(ls));
} else if (ls_restore_status.is_in_restore_and_before_quick_restore()) {
LOG_INFO("the log stream in restore and before quick restore, no need to record transfer info", "ls_id", ls->get_ls_id(), K(ls_restore_status));
} else if (!tablet_transfer_info.has_transfer_table()) {
} else if (ls_restore_status.is_before_restore_to_consistent_scn()) {
LOG_INFO("the log stream in restore is before restore to consistent scn, no need to record transfer info", "ls_id", ls->get_ls_id(), K(ls_restore_status));
}else if (!tablet_transfer_info.has_transfer_table()) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("tablet should have transfer table", K(ret), "ls_id", ls->get_ls_id(), K(tablet_id), K(tablet_transfer_info));
} else if (ls->get_ls_startup_transfer_info().is_valid()) {