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

yuzhou pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 2b51321  [ISSUE#3983] Optimize warn log output when sending exceptions 
are encountered. (#3984)
2b51321 is described below

commit 2b5132117929faadd77a364b0fe5913990d10450
Author: 彭小漪 <[email protected]>
AuthorDate: Mon Mar 14 20:47:36 2022 +0800

    [ISSUE#3983] Optimize warn log output when sending exceptions are 
encountered. (#3984)
---
 .../apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java    | 3 ---
 1 file changed, 3 deletions(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
 
b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
index f3f9caf..ea80478 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
@@ -630,9 +630,6 @@ public class DefaultMQProducerImpl implements 
MQProducerInner {
                         this.updateFaultItem(mq.getBrokerName(), endTimestamp 
- beginTimestampPrev, false);
                         log.warn(String.format("sendKernelImpl exception, 
throw exception, InvokeID: %s, RT: %sms, Broker: %s", invokeID, endTimestamp - 
beginTimestampPrev, mq), e);
                         log.warn(msg.toString());
-
-                        log.warn("sendKernelImpl exception", e);
-                        log.warn(msg.toString());
                         throw e;
                     }
                 } else {

Reply via email to