@@ -58,6 +58,8 @@ public static SeriesScanCostMetricSet getInstance() {
5858 public static final String TIMESERIES_METADATA = "timeseries_metadata" ;
5959 public static final String CHUNK = "chunk" ;
6060 private static final String DEVICE_ENTRY_DISK_READ_WRITE = "device_entry_disk_read_write" ;
61+ private static final String DEVICE_ENTRY_FETCH_SCHEMA = "device_entry_fetch_schema" ;
62+ private static final String DEVICE_ENTRY_DISTRIBUTION_PLAN = "device_entry_distribution_plan" ;
6163 private static final String FETCH_SCHEMA = "fetch_schema" ;
6264 private static final String DISTRIBUTION_PLAN = "distribution_plan" ;
6365
@@ -90,17 +92,13 @@ private void bindDeviceEntryDiskIO(AbstractMetricService metricService) {
9092 Metric .QUERY_DISK_READ .toString (),
9193 MetricLevel .IMPORTANT ,
9294 Tag .TYPE .toString (),
93- DEVICE_ENTRY_DISK_READ_WRITE ,
94- Tag .STAGE .toString (),
95- FETCH_SCHEMA );
95+ DEVICE_ENTRY_FETCH_SCHEMA );
9696 deviceEntryDistributionPlanDiskIOSize =
9797 metricService .getOrCreateCounter (
9898 Metric .QUERY_DISK_READ .toString (),
9999 MetricLevel .IMPORTANT ,
100100 Tag .TYPE .toString (),
101- DEVICE_ENTRY_DISK_READ_WRITE ,
102- Tag .STAGE .toString (),
103- DISTRIBUTION_PLAN );
101+ DEVICE_ENTRY_DISTRIBUTION_PLAN );
104102 deviceEntryFetchSchemaDiskIOTime =
105103 metricService .getOrCreateTimer (
106104 Metric .SERIES_SCAN_COST .toString (),
@@ -132,16 +130,12 @@ private void unbindDeviceEntryDiskIO(AbstractMetricService metricService) {
132130 MetricType .COUNTER ,
133131 Metric .QUERY_DISK_READ .toString (),
134132 Tag .TYPE .toString (),
135- DEVICE_ENTRY_DISK_READ_WRITE ,
136- Tag .STAGE .toString (),
137- FETCH_SCHEMA );
133+ DEVICE_ENTRY_FETCH_SCHEMA );
138134 metricService .remove (
139135 MetricType .COUNTER ,
140136 Metric .QUERY_DISK_READ .toString (),
141137 Tag .TYPE .toString (),
142- DEVICE_ENTRY_DISK_READ_WRITE ,
143- Tag .STAGE .toString (),
144- DISTRIBUTION_PLAN );
138+ DEVICE_ENTRY_DISTRIBUTION_PLAN );
145139 for (String type : Arrays .asList (FETCH_SCHEMA , DISTRIBUTION_PLAN )) {
146140 metricService .remove (
147141 MetricType .TIMER ,
0 commit comments