You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2022/03/14 12:47:45 UTC
[rocketmq] branch develop updated: [ISSUE#3983] Optimize warn log output when sending exceptions are encountered. (#3984)
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: 彭小漪 <64...@qq.com>
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 {