From 2d65ebabf1e515a17673f75934d7ac6d5be0d92a Mon Sep 17 00:00:00 2001 From: godyangfight Date: Thu, 8 Feb 2024 22:13:50 +0000 Subject: [PATCH] [CP] update ls meta migration status and restore status print log --- src/storage/high_availability/ob_rebuild_service.cpp | 3 ++- src/storage/ls/ob_ls_meta.cpp | 8 ++++++++ 2 files changed, 10 insertions(+), 1 deletion(-) diff --git a/src/storage/high_availability/ob_rebuild_service.cpp b/src/storage/high_availability/ob_rebuild_service.cpp index 33fb5953ba..e14b592469 100644 --- a/src/storage/high_availability/ob_rebuild_service.cpp +++ b/src/storage/high_availability/ob_rebuild_service.cpp @@ -727,7 +727,8 @@ int ObRebuildService::check_can_rebuild_( if (ObLSRebuildType::CLOG == rebuild_ctx.type_ && is_primary_tenant && 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; diff --git a/src/storage/ls/ob_ls_meta.cpp b/src/storage/ls/ob_ls_meta.cpp index 7192c81cc1..75322e9884 100644 --- a/src/storage/ls/ob_ls_meta.cpp +++ b/src/storage/ls/ob_ls_meta.cpp @@ -310,7 +310,10 @@ int ObLSMeta::set_migration_status(const ObMigrationStatus &migration_status, && OB_FAIL(set_finish_ha_state())) { LOG_WARN("set finish ha state failed", K(ret), K(ls_id_)); } else { + ObMigrationStatus original_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; @@ -403,7 +406,10 @@ int ObLSMeta::set_restore_status(const ObLSRestoreStatus &restore_status) && OB_FAIL(set_finish_ha_state())) { LOG_WARN("set finish ha state failed", KR(ret), K(ls_id_)); } else { + ObLSRestoreStatus original_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; @@ -547,6 +553,7 @@ int ObLSMeta::set_ls_rebuild() } else { migration_status_ = change_status; 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)); } else { rebuild_info_ = rebuild_info; + FLOG_INFO("succeed to set rebuild info", K(ls_id_), K(rebuild_info)); } } return ret;