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

[CP] fix job STATISTIC_PRIMARY_ZONE_ENTITY_COUNT

Browse Source
This commit is contained in:
wanhong.wwh
2022-05-25 20:51:07 +08:00
committed by wangzelin.wzl
parent 3025edd154
commit e48422a122
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/rootserver/ob_ddl_service.cpp
View File

@ -22386,6 +22386,7 @@ int ObDDLService::get_tenant_primary_zone_entity_count(
const uint64_t tenant_id, share::schema::ObSchemaGetterGuard &schema_guard, int64_t &pz_entity_count) const uint64_t tenant_id, share::schema::ObSchemaGetterGuard &schema_guard, int64_t &pz_entity_count)
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
int64_t table_pz_count = 0, db_pz_count = 0, tg_pz_count = 0;
common::ObArray<const ObDatabaseSchema *> database_schemas; common::ObArray<const ObDatabaseSchema *> database_schemas;
common::ObArray<const ObSimpleTableSchemaV2 *> table_schemas; common::ObArray<const ObSimpleTableSchemaV2 *> table_schemas;
common::ObArray<const ObTablegroupSchema *> tablegroup_schemas; common::ObArray<const ObTablegroupSchema *> tablegroup_schemas;
@ -22410,6 +22411,7 @@ int ObDDLService::get_tenant_primary_zone_entity_count(
// go on next // go on next
} else { } else {
++pz_entity_count; ++pz_entity_count;
table_pz_count++;
} }
} }
// databases // databases
@ -22422,6 +22424,7 @@ int ObDDLService::get_tenant_primary_zone_entity_count(
// go on next // go on next
} else { } else {
++pz_entity_count; ++pz_entity_count;
db_pz_count++;
} }
} }
for (int64_t i = 0; OB_SUCC(ret) && i < tablegroup_schemas.count(); ++i) { for (int64_t i = 0; OB_SUCC(ret) && i < tablegroup_schemas.count(); ++i) {
@ -22433,9 +22436,19 @@ int ObDDLService::get_tenant_primary_zone_entity_count(
// go on next // go on next
} else { } else {
++pz_entity_count; ++pz_entity_count;
tg_pz_count++;
} }
} }
} }
LOG_INFO("get tenant primary zone entity count",
K(tenant_id),
K(pz_entity_count),
K(table_pz_count),
K(db_pz_count),
K(tg_pz_count),
KR(ret));
return ret; return ret;
} }