You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2021/09/30 17:47:08 UTC
[pulsar] branch master updated: [Java Client] Remove unnecessary
stats incremement (#12229)
This is an automated email from the ASF dual-hosted git repository.
mmerli 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 9d30914 [Java Client] Remove unnecessary stats incremement (#12229)
9d30914 is described below
commit 9d309145f342bc416b8b4663125e1216903a3e83
Author: Michael Marshall <mi...@gmail.com>
AuthorDate: Thu Sep 30 12:46:11 2021 -0500
[Java Client] Remove unnecessary stats incremement (#12229)
---
.../src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java
index 1d7611b..d0d3db1 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java
@@ -1677,7 +1677,6 @@ public class ProducerImpl<T> extends ProducerBase<T> implements TimerTask, Conne
format("The producer %s can not send message to the topic %s within given timeout",
producerName, topic), firstMsg.sequenceId);
failPendingMessages(cnx(), te);
- stats.incrementSendFailed(pendingMessages.size());
// Since the pending queue is cleared now, set timer to expire after configured value.
timeToWaitMs = conf.getSendTimeoutMs();
} else {