From ec87a16a28b799b8c833ffb1f18d5af6b3bec05a Mon Sep 17 00:00:00 2001
From: Weihao Li <18110526956@163.com>
Date: Wed, 9 Sep 2026 11:37:26 +0800
Subject: [PATCH] fix

Signed-off-by: Weihao Li <18110526956@163.com>
---
 .../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 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,