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 {