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

[CP] fix: job for other tenant cannot be execute when check_new_jobs failed

Browse Source
This commit is contained in:
obdev
2023-09-20 15:40:22 +00:00
committed by ob-robot
parent b6ac71b4b8
commit 2cea3df3fb
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/observer/dbms_scheduler/ob_dbms_sched_job_master.cpp
View File

@ -562,7 +562,7 @@ int ObDBMSSchedJobMaster::check_all_tenants()
} else if (OB_FAIL(schema_guard.get_tenant_ids(tenant_ids))) { } else if (OB_FAIL(schema_guard.get_tenant_ids(tenant_ids))) {
LOG_WARN("fail to get all tenant ids", K(ret)); LOG_WARN("fail to get all tenant ids", K(ret));
} else { } else {
for (int64_t i = 0; OB_SUCC(ret) && i < tenant_ids.count(); ++i) { for (int64_t i = 0; i < tenant_ids.count(); ++i) {
const ObTenantSchema *tenant_schema = NULL; const ObTenantSchema *tenant_schema = NULL;
OZ (schema_guard.get_tenant_info(tenant_ids.at(i), tenant_schema)); OZ (schema_guard.get_tenant_info(tenant_ids.at(i), tenant_schema));
CK (OB_NOT_NULL(tenant_schema)); CK (OB_NOT_NULL(tenant_schema));
@ -577,6 +577,7 @@ int ObDBMSSchedJobMaster::check_all_tenants()
} }
OZ (check_new_jobs(tenant_ids.at(i), tenant_schema->is_oracle_tenant())); OZ (check_new_jobs(tenant_ids.at(i), tenant_schema->is_oracle_tenant()));
} }
ret = OB_SUCCESS; // one tenant failed should not affect other
} }
} }
LOG_INFO("check all tenants", K(ret)); LOG_INFO("check all tenants", K(ret));