fix (#16773)

Author: Caideyipi

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/DataNodeMemoryConfig.java

@@ -32,6 +32,10 @@
 public class DataNodeMemoryConfig {
   private static final Logger LOGGER = LoggerFactory.getLogger(DataNodeMemoryConfig.class);
 
+  public static final String SCHEMA_CACHE = "SchemaCache";
+  public static final String SCHEMA_REGION = "SchemaRegion";
+  public static final String PARTITION_CACHE = "PartitionCache";
+
   /** Reject proportion for system */
   private double rejectProportion = 0.8;
 
@@ -266,13 +270,13 @@ private void initSchemaMemoryAllocate(
 
     schemaRegionMemoryManager =
         schemaEngineMemoryManager.getOrCreateMemoryManager(
-            "SchemaRegion", schemaMemoryTotal * schemaMemoryProportion[0] / proportionSum);
+            SCHEMA_REGION, schemaMemoryTotal * schemaMemoryProportion[0] / proportionSum);
     schemaCacheMemoryManager =
         schemaEngineMemoryManager.getOrCreateMemoryManager(
-            "SchemaCache", schemaMemoryTotal * schemaMemoryProportion[1] / proportionSum);
+            SCHEMA_CACHE, schemaMemoryTotal * schemaMemoryProportion[1] / proportionSum);
     partitionCacheMemoryManager =
         schemaEngineMemoryManager.getOrCreateMemoryManager(
-            "PartitionCache", schemaMemoryTotal * schemaMemoryProportion[2] / proportionSum);
+            PARTITION_CACHE, schemaMemoryTotal * schemaMemoryProportion[2] / proportionSum);
 
     LOGGER.info(
         "allocateMemoryForSchemaRegion = {}",

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/partition/PartitionCache.java

@@ -128,7 +128,7 @@ public PartitionCache() {
     this.memoryBlock =
         memoryConfig
             .getPartitionCacheMemoryManager()
-            .exactAllocate("PartitionCache", MemoryBlockType.STATIC);
+            .exactAllocate(DataNodeMemoryConfig.PARTITION_CACHE, MemoryBlockType.STATIC);
     this.memoryBlock.allocate(this.memoryBlock.getTotalMemorySizeInBytes());
     // TODO @spricoder: PartitionCache need to be controlled according to memory
     this.schemaPartitionCache =

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/TableDeviceSchemaCache.java

@@ -112,7 +112,7 @@ private TableDeviceSchemaCache() {
     memoryBlock =
         memoryConfig
             .getSchemaCacheMemoryManager()
-            .exactAllocate("TableDeviceSchemaCache", MemoryBlockType.STATIC);
+            .exactAllocate(DataNodeMemoryConfig.SCHEMA_CACHE, MemoryBlockType.STATIC);
     dualKeyCache =
         new DualKeyCacheBuilder<TableId, IDeviceID, TableDeviceCacheEntry>()
             .cacheEvictionPolicy(

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/TableDeviceSchemaCacheMetrics.java

@@ -21,6 +21,7 @@
 
 import org.apache.iotdb.commons.service.metric.enums.Metric;
 import org.apache.iotdb.commons.service.metric.enums.Tag;
+import org.apache.iotdb.db.conf.DataNodeMemoryConfig;
 import org.apache.iotdb.metrics.AbstractMetricService;
 import org.apache.iotdb.metrics.metricsets.IMetricSet;
 import org.apache.iotdb.metrics.utils.MetricLevel;
@@ -47,7 +48,7 @@ public void bindTo(final AbstractMetricService metricService) {
         tableDeviceSchemaCache,
         TableDeviceSchemaCache::getHitCount,
         Tag.NAME.toString(),
-        "SchemaCache",
+        DataNodeMemoryConfig.SCHEMA_CACHE,
         Tag.TYPE.toString(),
         "hit");
     metricService.createAutoGauge(
@@ -56,7 +57,7 @@ public void bindTo(final AbstractMetricService metricService) {
         tableDeviceSchemaCache,
         TableDeviceSchemaCache::getRequestCount,
         Tag.NAME.toString(),
-        "SchemaCache",
+        DataNodeMemoryConfig.SCHEMA_CACHE,
         Tag.TYPE.toString(),
         "all");
     metricService.createAutoGauge(
@@ -86,14 +87,14 @@ public void unbindFrom(final AbstractMetricService metricService) {
         MetricType.AUTO_GAUGE,
         Metric.CACHE.toString(),
         Tag.NAME.toString(),
-        "SchemaCache",
+        DataNodeMemoryConfig.SCHEMA_CACHE,
         Tag.TYPE.toString(),
         "hit");
     metricService.remove(
         MetricType.AUTO_GAUGE,
         Metric.CACHE.toString(),
         Tag.NAME.toString(),
-        "SchemaCache",
+        DataNodeMemoryConfig.SCHEMA_CACHE,
         Tag.TYPE.toString(),
         "all");
     metricService.remove(

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/rescon/MemSchemaEngineStatistics.java

@@ -21,6 +21,7 @@
 
 import org.apache.iotdb.commons.memory.IMemoryBlock;
 import org.apache.iotdb.commons.memory.MemoryBlockType;
+import org.apache.iotdb.db.conf.DataNodeMemoryConfig;
 import org.apache.iotdb.db.conf.IoTDBDescriptor;
 import org.apache.iotdb.db.schemaengine.SchemaEngine;
 import org.apache.iotdb.db.schemaengine.template.ClusterTemplateManager;
@@ -41,7 +42,7 @@ public class MemSchemaEngineStatistics implements ISchemaEngineStatistics {
       IoTDBDescriptor.getInstance()
           .getMemoryConfig()
           .getSchemaRegionMemoryManager()
-          .exactAllocate("SchemaRegion", MemoryBlockType.DYNAMIC);
+          .exactAllocate(DataNodeMemoryConfig.SCHEMA_REGION, MemoryBlockType.DYNAMIC);
   private final ClusterTemplateManager clusterTemplateManager =
       ClusterTemplateManager.getInstance();