You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/02/16 01:16:09 UTC
[pulsar] 08/08: Fix time unit error in errMsg when producer send fails. (#14299)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 4c016b987e3f55d40307aa24f190427378545039
Author: JiangHaiting <ji...@apache.org>
AuthorDate: Wed Feb 16 00:07:23 2022 +0800
Fix time unit error in errMsg when producer send fails. (#14299)
(cherry picked from commit 5bcdb5ef40a24fefad042efac484f2be4b92c527)
---
.../src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java | 3 ++-
1 file changed, 2 insertions(+), 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
index 8486283..dc651f3 100644
--- 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
@@ -1249,7 +1249,8 @@ public class ProducerImpl<T> extends ProducerBase<T> implements TimerTask, Conne
long sequenceId = te.getSequenceId();
long ns = System.nanoTime();
String errMsg = String.format(
- "%s : createdAt %s ns ago, firstSentAt %s ns ago, lastSentAt %s ns ago, retryCount %s",
+ "%s : createdAt %s seconds ago, firstSentAt %s seconds ago, lastSentAt %s seconds ago, "
+ + "retryCount %s",
te.getMessage(),
RelativeTimeUtil.nsToSeconds(ns - this.createdAt),
RelativeTimeUtil.nsToSeconds(this.firstSentAt <= 0 ? ns - this.lastSentAt : ns - this.firstSentAt),