[pulsar] branch master updated: [Java Client] Remove unnecessary stats incremement (#12229)

[mmerli]

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 <mikemars...@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 {