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

[CP] fix unstable cases

Browse Source
This commit is contained in:
wxhwang 2024-04-19 05:26:43 +00:00 committed by ob-robot
parent 948ac8764c
commit 284612e22d
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/rootserver/ob_root_service.cpp
View File

@ -110,6 +110,7 @@
#include "rootserver/backup/ob_backup_proxy.h" //ObBackupServiceProxy
#include "logservice/palf_handle_guard.h"
#include "logservice/ob_log_service.h"
#include "rootserver/restore/ob_restore_service.h"
#include "rootserver/restore/ob_recover_table_initiator.h"
#include "rootserver/ob_heartbeat_service.h"
#include "share/tenant_snapshot/ob_tenant_snapshot_table_operator.h"
@ -11414,6 +11415,13 @@ int ObRootService::handle_recover_table(const obrpc::ObRecoverTableArg &arg)
} else if (OB_FAIL(initiator.initiate_recover_table(arg))) {
LOG_WARN("failed to initiate table recover", K(ret), K(arg));
} else {
// wake up restore thread
ObRestoreService *restore_service = nullptr;
if (OB_ISNULL(restore_service = MTL(ObRestoreService *))) {
LOG_ERROR_RET(OB_ERR_UNEXPECTED, "restore service must not be null");
} else {
restore_service->wakeup();
}
LOG_INFO("[RECOVER_TABLE] initiate recover table succeed", K(arg));
}
}