diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/metric/SeriesScanCostMetricSet.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/metric/SeriesScanCostMetricSet.java index ff0508149fc3..45034633b670 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/metric/SeriesScanCostMetricSet.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/metric/SeriesScanCostMetricSet.java @@ -58,6 +58,8 @@ public static SeriesScanCostMetricSet getInstance() { public static final String TIMESERIES_METADATA = "timeseries_metadata"; public static final String CHUNK = "chunk"; private static final String DEVICE_ENTRY_DISK_READ_WRITE = "device_entry_disk_read_write"; + private static final String DEVICE_ENTRY_FETCH_SCHEMA = "device_entry_fetch_schema"; + private static final String DEVICE_ENTRY_DISTRIBUTION_PLAN = "device_entry_distribution_plan"; private static final String FETCH_SCHEMA = "fetch_schema"; private static final String DISTRIBUTION_PLAN = "distribution_plan"; @@ -90,17 +92,13 @@ private void bindDeviceEntryDiskIO(AbstractMetricService metricService) { Metric.QUERY_DISK_READ.toString(), MetricLevel.IMPORTANT, Tag.TYPE.toString(), - DEVICE_ENTRY_DISK_READ_WRITE, - Tag.STAGE.toString(), - FETCH_SCHEMA); + DEVICE_ENTRY_FETCH_SCHEMA); deviceEntryDistributionPlanDiskIOSize = metricService.getOrCreateCounter( Metric.QUERY_DISK_READ.toString(), MetricLevel.IMPORTANT, Tag.TYPE.toString(), - DEVICE_ENTRY_DISK_READ_WRITE, - Tag.STAGE.toString(), - DISTRIBUTION_PLAN); + DEVICE_ENTRY_DISTRIBUTION_PLAN); deviceEntryFetchSchemaDiskIOTime = metricService.getOrCreateTimer( Metric.SERIES_SCAN_COST.toString(), @@ -132,16 +130,12 @@ private void unbindDeviceEntryDiskIO(AbstractMetricService metricService) { MetricType.COUNTER, Metric.QUERY_DISK_READ.toString(), Tag.TYPE.toString(), - DEVICE_ENTRY_DISK_READ_WRITE, - Tag.STAGE.toString(), - FETCH_SCHEMA); + DEVICE_ENTRY_FETCH_SCHEMA); metricService.remove( MetricType.COUNTER, Metric.QUERY_DISK_READ.toString(), Tag.TYPE.toString(), - DEVICE_ENTRY_DISK_READ_WRITE, - Tag.STAGE.toString(), - DISTRIBUTION_PLAN); + DEVICE_ENTRY_DISTRIBUTION_PLAN); for (String type : Arrays.asList(FETCH_SCHEMA, DISTRIBUTION_PLAN)) { metricService.remove( MetricType.TIMER,