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/12/20 13:14:06 UTC
[pulsar] 14/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.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 7e97e6cc8ddac16b26a8ab6161b91221ceac470b
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 f8e59a2..e28721c 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
@@ -1227,7 +1227,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
);