You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ti...@apache.org on 2021/04/20 03:09:11 UTC
[rocketmq] branch develop updated: [ISSUE #2538]Optimize log output
when message trace saving fails
This is an automated email from the ASF dual-hosted git repository.
tigerlee 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 0720f0e [ISSUE #2538]Optimize log output when message trace saving fails
new 7ee2cd3 Merge pull request #2822 from zhangjidi2016/develop
0720f0e is described below
commit 0720f0eb531b6545b95b530179850013adcfad91
Author: zhangjidi2016 <zh...@cmss.chinamobile.com>
AuthorDate: Fri Apr 16 17:06:48 2021 +0800
[ISSUE #2538]Optimize log output when message trace saving fails
---
.../java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java b/client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java
index 05a95e8..8210b41 100644
--- a/client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java
+++ b/client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java
@@ -370,7 +370,7 @@ public class AsyncTraceDispatcher implements TraceDispatcher {
@Override
public void onException(Throwable e) {
- log.info("send trace data ,the traceData is " + data);
+ log.error("send trace data failed, the traceData is {}", data, e);
}
};
if (traceBrokerSet.isEmpty()) {
@@ -398,7 +398,7 @@ public class AsyncTraceDispatcher implements TraceDispatcher {
}
} catch (Exception e) {
- log.info("send trace data,the traceData is" + data);
+ log.error("send trace data failed, the traceData is {}", data, e);
}
}