You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/09/16 05:04:35 UTC

[rocketmq-exporter] branch master updated: fix metrics (#113)

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

duhengforever pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git


The following commit(s) were added to refs/heads/master by this push:
     new fc42cf7  fix metrics (#113)
fc42cf7 is described below

commit fc42cf77b585a91f7d0ec713677da30242a0dc38
Author: HuiTong <yi...@163.com>
AuthorDate: Fri Sep 16 13:04:30 2022 +0800

    fix metrics (#113)
    
    Co-authored-by: huitong <yi...@alibaba-inc.com>
---
 pom.xml                                                                | 3 +++
 .../java/org/apache/rocketmq/exporter/model/BrokerRuntimeStats.java    | 2 +-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/pom.xml b/pom.xml
index 0bee298..a65c019 100644
--- a/pom.xml
+++ b/pom.xml
@@ -76,6 +76,9 @@
             <plugin>
                 <groupId>org.springframework.boot</groupId>
                 <artifactId>spring-boot-maven-plugin</artifactId>
+                <configuration>
+                    <classifier>exec</classifier>
+                </configuration>
             </plugin>
             <plugin>
                 <artifactId>maven-checkstyle-plugin</artifactId>
diff --git a/src/main/java/org/apache/rocketmq/exporter/model/BrokerRuntimeStats.java b/src/main/java/org/apache/rocketmq/exporter/model/BrokerRuntimeStats.java
index 4a91504..779f87b 100644
--- a/src/main/java/org/apache/rocketmq/exporter/model/BrokerRuntimeStats.java
+++ b/src/main/java/org/apache/rocketmq/exporter/model/BrokerRuntimeStats.java
@@ -88,7 +88,7 @@ public class BrokerRuntimeStats {
 
         loadTps(this.putTps, kvTable.getTable().get("putTps"));
         loadTps(this.getMissTps, kvTable.getTable().get("getMissTps"));
-        loadTps(this.getTransferedTps, kvTable.getTable().get("getTransferedTps"));
+        loadTps(this.getTransferedTps, kvTable.getTable().get("getTransferredTps"));
         loadTps(this.getTotalTps, kvTable.getTable().get("getTotalTps"));
         loadTps(this.getFoundTps, kvTable.getTable().get("getFoundTps"));