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

[CP] update ls meta migration status and restore status print log

Browse Source
This commit is contained in:
godyangfight
2024-02-08 22:13:50 +00:00
committed by ob-robot
parent 019a7858cc
commit 2d65ebabf1
2 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/storage/high_availability/ob_rebuild_service.cpp
View File

@ -727,7 +727,8 @@ int ObRebuildService::check_can_rebuild_(
if (ObLSRebuildType::CLOG == rebuild_ctx.type_ if (ObLSRebuildType::CLOG == rebuild_ctx.type_
&& is_primary_tenant && is_primary_tenant
&& member_list.contains(self_addr)) { && member_list.contains(self_addr)) {
LOG_ERROR("paxos member lost clog, need rebuild", "ls_id", ls->get_ls_id(), K(role)); LOG_ERROR("paxos member lost clog, need rebuild", "tenant_id", ls->get_tenant_id(),
"ls_id", ls->get_ls_id(), K(role));
} }
} }
return ret; return ret;

8
src/storage/ls/ob_ls_meta.cpp
View File

@ -310,7 +310,10 @@ int ObLSMeta::set_migration_status(const ObMigrationStatus &migration_status,
&& OB_FAIL(set_finish_ha_state())) { && OB_FAIL(set_finish_ha_state())) {
LOG_WARN("set finish ha state failed", K(ret), K(ls_id_)); LOG_WARN("set finish ha state failed", K(ret), K(ls_id_));
} else { } else {
ObMigrationStatus original_status = migration_status_;
migration_status_ = migration_status; migration_status_ = migration_status;
FLOG_INFO("succeed to set ls migration status", K(ls_id_), "original status",
original_status, "current status", migration_status);
} }
} }
return ret; return ret;
@ -403,7 +406,10 @@ int ObLSMeta::set_restore_status(const ObLSRestoreStatus &restore_status)
&& OB_FAIL(set_finish_ha_state())) { && OB_FAIL(set_finish_ha_state())) {
LOG_WARN("set finish ha state failed", KR(ret), K(ls_id_)); LOG_WARN("set finish ha state failed", KR(ret), K(ls_id_));
} else { } else {
ObLSRestoreStatus original_status = restore_status_;
restore_status_ = restore_status; restore_status_ = restore_status;
FLOG_INFO("succeed to set ls restore status", K(ls_id_), "original status",
original_status, "current status", restore_status);
} }
} }
return ret; return ret;
@ -547,6 +553,7 @@ int ObLSMeta::set_ls_rebuild()
} else { } else {
migration_status_ = change_status; migration_status_ = change_status;
rebuild_seq_ = tmp.rebuild_seq_; rebuild_seq_ = tmp.rebuild_seq_;
FLOG_INFO("succeed to set ls rebuild", "ls_id", ls_id_, KPC(this));
} }
} }
} }
@ -777,6 +784,7 @@ int ObLSMeta::set_rebuild_info(const ObLSRebuildInfo &rebuild_info)
LOG_WARN("rebuild_info write slog failed", K(ret)); LOG_WARN("rebuild_info write slog failed", K(ret));
} else { } else {
rebuild_info_ = rebuild_info; rebuild_info_ = rebuild_info;
FLOG_INFO("succeed to set rebuild info", K(ls_id_), K(rebuild_info));
} }
} }
return ret; return ret;