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

Fix the processing of notifying ObTenantSnapshotService when deleting unit

Browse Source
This commit is contained in:
obdev
2024-02-08 08:54:15 +00:00
committed by ob-robot
parent 74ecfad3a5
commit aeff383709
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/observer/omt/ob_tenant_node_balancer.cpp
View File

@ -516,7 +516,11 @@ int ObTenantNodeBalancer::fetch_effective_tenants(const TenantUnits &old_tenants
bool is_tenant_snapshot_released = false; bool is_tenant_snapshot_released = false;
if (is_user_tenant(tenant_config.tenant_id_)) { if (is_user_tenant(tenant_config.tenant_id_)) {
MTL(ObTenantSnapshotService*)->notify_unit_is_deleting(); const int64_t now_time = ObTimeUtility::current_time();
const int64_t life_time = now_time - tenant_config.create_timestamp_;
if (tenant_config.is_removed_ || life_time >= RECYCLE_LATENCY) {
MTL(ObTenantSnapshotService*)->notify_unit_is_deleting();
}
if (OB_FAIL(MTL(ObTenantSnapshotService*)-> if (OB_FAIL(MTL(ObTenantSnapshotService*)->
check_all_tenant_snapshot_released(is_tenant_snapshot_released))) { check_all_tenant_snapshot_released(is_tenant_snapshot_released))) {
LOG_WARN("fail to check_all_tenant_snapshot_released", K(ret), K(tenant_config)); LOG_WARN("fail to check_all_tenant_snapshot_released", K(ret), K(tenant_config));