You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by yu...@apache.org on 2023/05/07 22:38:44 UTC

[pulsar] branch branch-3.0 updated: [fix] [broker] error TimeUnit to record publish latency (#20074)

This is an automated email from the ASF dual-hosted git repository.

yubiao pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new c7cffba6b62 [fix] [broker] error TimeUnit to record publish latency (#20074)
c7cffba6b62 is described below

commit c7cffba6b623183f82ec48c6c83a098dcd1a1fa8
Author: ken <16...@qq.com>
AuthorDate: Thu Apr 13 01:22:02 2023 +0800

    [fix] [broker] error TimeUnit to record publish latency (#20074)
    
    Co-authored-by: fanjianye <fa...@bigo.sg>
    Co-authored-by: tison <wa...@gmail.com>
    (cherry picked from commit 547d792439e7b8bfefb0236b078ed145731da658)
---
 .../java/org/apache/pulsar/broker/rest/RestMessagePublishContext.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/RestMessagePublishContext.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/RestMessagePublishContext.java
index d7cee8b600b..3c9adbd3e4f 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/RestMessagePublishContext.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/RestMessagePublishContext.java
@@ -53,7 +53,7 @@ public class RestMessagePublishContext implements Topic.PublishContext {
                                 + "triggered send callback.",
                         topic.getName(), ledgerId, entryId);
             }
-            topic.recordAddLatency(System.nanoTime() - startTimeNs, TimeUnit.MICROSECONDS);
+            topic.recordAddLatency(System.nanoTime() - startTimeNs, TimeUnit.NANOSECONDS);
             positionFuture.complete(PositionImpl.get(ledgerId, entryId));
         }
         recycle();