You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2022/12/30 12:01:57 UTC

[iotdb] branch lmh/fixMetric created (now 2d3623092a)

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

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


      at 2d3623092a fix

This branch includes the following new commits:

     new 2d3623092a fix

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



[iotdb] 01/01: fix

Posted by hu...@apache.org.
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 <li...@foxmail.com>
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);
   }
 }