You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2022/02/24 06:34:59 UTC
[pulsar] 01/03: Fix time unit error in errMsg when producer send fails. (#14299)
This is an automated email from the ASF dual-hosted git repository.
mmarshall pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit d99b60914cca88f1b5b7fdc92ff58223f1bd76c1
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 6b23565..9dd2e01 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
@@ -1220,7 +1220,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),