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

hui pushed a commit to branch lmh/fixMetric
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 2d3623092a9c1dd6611e96ada462a426a98b4bd5
Author: Minghui Liu <[email protected]>
AuthorDate: Fri Dec 30 20:01:31 2022 +0800

    fix
---
 .../java/org/apache/iotdb/db/mpp/metric/DataExchangeMetricSet.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/metric/DataExchangeMetricSet.java
 
b/server/src/main/java/org/apache/iotdb/db/mpp/metric/DataExchangeMetricSet.java
index 20340b3ada..004b640d71 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/mpp/metric/DataExchangeMetricSet.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/mpp/metric/DataExchangeMetricSet.java
@@ -178,7 +178,7 @@ public class DataExchangeMetricSet implements IMetricSet {
       metricService.getOrCreateTimer(
           metricInfo.getName(), MetricLevel.IMPORTANT, 
metricInfo.getTagsInArray());
     }
-    metricService.getOrCreateRate(
+    metricService.getOrCreateHistogram(
         Metric.DATA_EXCHANGE_COUNT.toString(),
         MetricLevel.IMPORTANT,
         Tag.NAME.toString(),
@@ -190,6 +190,6 @@ public class DataExchangeMetricSet implements IMetricSet {
     for (MetricInfo metricInfo : metricInfoMap.values()) {
       metricService.remove(MetricType.TIMER, metric, 
metricInfo.getTagsInArray());
     }
-    metricService.remove(MetricType.RATE, metric, Tag.NAME.toString(), 
GET_DATA_BLOCK_NUM);
+    metricService.remove(MetricType.HISTOGRAM, metric, Tag.NAME.toString(), 
GET_DATA_BLOCK_NUM);
   }
 }

Reply via email to