[pulsar] branch master updated: fix: fix ProducerStatsRecorderImpl.updateCumulativeStats (#6996)

[nkurihar]

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

nkurihar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new cf99e90  fix: fix ProducerStatsRecorderImpl.updateCumulativeStats 
(#6996)
cf99e90 is described below

commit cf99e90123534733f0f9c08d5e5e534721c00fce
Author: Yuri Mizushima <yumiz...@yahoo-corp.jp>
AuthorDate: Mon Jun 1 08:31:48 2020 +0900

    fix: fix ProducerStatsRecorderImpl.updateCumulativeStats (#6996)
---
 .../org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java  | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java
 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java
index fde2d75..16d0dc9 100644
--- 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java
+++ 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java
@@ -214,10 +214,10 @@ public class ProducerStatsRecorderImpl implements 
ProducerStatsRecorder {
         numBytesSent.add(stats.getNumBytesSent());
         numSendFailed.add(stats.getNumSendFailed());
         numAcksReceived.add(stats.getNumAcksReceived());
-        totalMsgsSent.add(stats.getNumMsgsSent());
-        totalBytesSent.add(stats.getNumBytesSent());
-        totalSendFailed.add(stats.getNumSendFailed());
-        totalAcksReceived.add(stats.getNumAcksReceived());
+        totalMsgsSent.add(stats.getTotalMsgsSent());
+        totalBytesSent.add(stats.getTotalBytesSent());
+        totalSendFailed.add(stats.getTotalSendFailed());
+        totalAcksReceived.add(stats.getTotalAcksReceived());
     }
 
     @Override