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 2021/11/18 06:27:29 UTC
[pulsar] 06/15: Fix invalid firstSentAt value (#12588)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit eccacaff87dc14b0a702c1e211460a8fb25410a1
Author: Zhanpeng Wu <zh...@qq.com>
AuthorDate: Thu Nov 4 23:15:34 2021 +0800
Fix invalid firstSentAt value (#12588)
(cherry picked from commit 2ca96e4e0e63f99af0b079f3d590bbc8aa179676)
---
.../src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java | 2 +-
1 file changed, 1 insertion(+), 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 239ee60..fa7f364 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
@@ -1202,7 +1202,7 @@ public class ProducerImpl<T> extends ProducerBase<T> implements TimerTask, Conne
"%s : createdAt %s ns ago, firstSentAt %s ns ago, lastSentAt %s ns ago, retryCount %s",
te.getMessage(),
ns - this.createdAt,
- ns - this.firstSentAt,
+ this.firstSentAt <= 0 ? ns - this.lastSentAt : ns - this.firstSentAt,
ns - this.lastSentAt,
retryCount
);