This is an automated email from the ASF dual-hosted git repository. Wei-hao-Li pushed a commit to branch fixMetric in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ec87a16a28b799b8c833ffb1f18d5af6b3bec05a Author: Weihao Li <[email protected]> AuthorDate: Wed Sep 9 11:37:26 2026 +0800 fix Signed-off-by: Weihao Li <[email protected]> --- .../db/queryengine/metric/SeriesScanCostMetricSet.java | 18 ++++++------------ 1 file changed, 6 insertions(+), 12 deletions(-) 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 ff0508149fc..45034633b67 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 class SeriesScanCostMetricSet implements IMetricSet { 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 @@ public class SeriesScanCostMetricSet implements IMetricSet { 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 @@ public class SeriesScanCostMetricSet implements IMetricSet { 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,
