You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by nk...@apache.org on 2020/05/31 23:32:00 UTC
[pulsar] branch master updated: fix: fix
ProducerStatsRecorderImpl.updateCumulativeStats (#6996)
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 <yu...@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