This is an automated email from the ASF dual-hosted git repository. yongzao pushed a commit to branch Control-the-RegionGroup-number-of-system-Database in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1689569781d7d8740b4156d4df551aaca8c1d10d Author: YongzaoDan <[email protected]> AuthorDate: Thu Jun 15 20:29:04 2023 +0800 Finish --- .../iotdb/confignode/manager/schema/ClusterSchemaManager.java | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/schema/ClusterSchemaManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/schema/ClusterSchemaManager.java index 355e6744878..1826e231606 100644 --- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/schema/ClusterSchemaManager.java +++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/schema/ClusterSchemaManager.java @@ -76,6 +76,7 @@ import org.apache.iotdb.db.metadata.template.TemplateInternalRPCUpdateType; import org.apache.iotdb.db.metadata.template.TemplateInternalRPCUtil; import org.apache.iotdb.db.metadata.template.alter.TemplateExtendInfo; import org.apache.iotdb.db.utils.SchemaUtils; +import org.apache.iotdb.metrics.utils.IoTDBMetricsUtils; import org.apache.iotdb.mpp.rpc.thrift.TUpdateTemplateReq; import org.apache.iotdb.rpc.RpcUtils; import org.apache.iotdb.rpc.TSStatusCode; @@ -400,14 +401,20 @@ public class ClusterSchemaManager { int databaseNum = databaseSchemaMap.size(); for (TDatabaseSchema databaseSchema : databaseSchemaMap.values()) { - if (!isDatabaseExist(databaseSchema.getName())) { - // filter the pre deleted database + if (!isDatabaseExist(databaseSchema.getName()) + || databaseSchema.getName().equals(IoTDBMetricsUtils.DATABASE)) { + // filter the pre deleted database and the system database databaseNum--; } } AdjustMaxRegionGroupNumPlan adjustMaxRegionGroupNumPlan = new AdjustMaxRegionGroupNumPlan(); for (TDatabaseSchema databaseSchema : databaseSchemaMap.values()) { + if (databaseSchema.getName().equals(IoTDBMetricsUtils.DATABASE)) { + // filter the system database + continue; + } + try { // Adjust maxSchemaRegionGroupNum for each Database. // All Databases share the DataNodes equally.
