(iotdb) branch master updated: Fix metric about device entry disk io- #18609

[jackietien]

This is an automated email from the ASF dual-hosted git repository.

JackieTien97 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 31621ef2602 Fix metric about device entry disk io- #18609
31621ef2602 is described below

commit 31621ef26022f682540e330b3515fca01253cba8
Author: Weihao Li <60659567+wei-hao...@users.noreply.github.com>
AuthorDate: Fri Sep 11 10:13:25 2026 +0800

    Fix metric about device entry disk io- #18609
---
 .../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,