(rocketmq-exporter) branch master updated: Revert #108 "metrics bugfix: switch getTps() to getSum()" (#141)

[cserwen]

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

cserwen 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 5ac38b7  Revert #108 "metrics bugfix: switch getTps() to getSum()" 
(#141)
5ac38b7 is described below

commit 5ac38b7a692479504715866b61908d225af0d824
Author: cserwen <cser...@apache.org>
AuthorDate: Tue Jan 16 12:09:48 2024 +0800

    Revert #108 "metrics bugfix: switch getTps() to getSum()" (#141)
---
 .../org/apache/rocketmq/exporter/task/MetricsCollectTask.java  | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java 
b/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java
index 7f4b940..e465c57 100644
--- a/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java
+++ b/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java
@@ -470,7 +470,7 @@ public class MetricsCollectTask {
                             bd.getBrokerName(),
                             brokerIP,
                             topic,
-                            Utils.getFixedDouble(bsd.getStatsMinute().getSum())
+                            Utils.getFixedDouble(bsd.getStatsMinute().getTps())
                         );
                     } catch (MQClientException ex) {
                         if (ex.getResponseCode() == ResponseCode.SYSTEM_ERROR) 
{
@@ -490,7 +490,7 @@ public class MetricsCollectTask {
                             bd.getBrokerName(),
                             brokerIP,
                             topic,
-                            Utils.getFixedDouble(bsd.getStatsMinute().getSum())
+                            Utils.getFixedDouble(bsd.getStatsMinute().getTps())
                         );
                     } catch (MQClientException ex) {
                         if (ex.getResponseCode() == ResponseCode.SYSTEM_ERROR) 
{
@@ -529,7 +529,7 @@ public class MetricsCollectTask {
                                 bd.getBrokerName(),
                                 topic,
                                 group,
-                                
Utils.getFixedDouble(bsd.getStatsMinute().getSum()));
+                                
Utils.getFixedDouble(bsd.getStatsMinute().getTps()));
                         } catch (MQClientException ex) {
                             if (ex.getResponseCode() == 
ResponseCode.SYSTEM_ERROR) {
                                 
//log.error(String.format("GROUP_GET_NUMS-error, topic=%s, group=%s,master 
broker=%s, %s", topic, group, masterAddr, ex.getErrorMessage()));
@@ -547,7 +547,7 @@ public class MetricsCollectTask {
                                 bd.getBrokerName(),
                                 topic,
                                 group,
-                                
Utils.getFixedDouble(bsd.getStatsMinute().getSum()));
+                                
Utils.getFixedDouble(bsd.getStatsMinute().getTps()));
                         } catch (MQClientException ex) {
                             if (ex.getResponseCode() == 
ResponseCode.SYSTEM_ERROR) {
                                 // 
log.error(String.format("GROUP_GET_SIZE-error, topic=%s, group=%s, master 
broker=%s, %s", topic, group, masterAddr, ex.getErrorMessage()));
@@ -613,7 +613,7 @@ public class MetricsCollectTask {
                     clusterName,
                     brokerIP,
                     brokerName,
-                    Utils.getFixedDouble(bsd.getStatsMinute().getSum()));
+                    Utils.getFixedDouble(bsd.getStatsMinute().getTps()));
             } catch (MQClientException ex) {
                 if (ex.getResponseCode() == ResponseCode.SYSTEM_ERROR) {
                     // log.error(String.format("GROUP_GET_SIZE-error, 
topic=%s, group=%s, master broker=%s, %s", topic, group, masterAddr, 
ex.getErrorMessage()));