[Java Client] Remove unnecessary stats incremement (apache#12229)

lujp · Sep 30, 2021 · 9d30914 · 9d30914
1 parent 14fc0d3
commit 9d30914
Showing 1 changed file with 0 additions and 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
@@ -1677,7 +1677,6 @@ public void run(Timeout timeout) throws Exception {
                         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 {