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/04/19 14:33:11 UTC
[pulsar] branch master updated: [ISSUE 10153][Go Function] fix time
unit ns -> ms (#10160)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new e9bf54a [ISSUE 10153][Go Function] fix time unit ns -> ms (#10160)
e9bf54a is described below
commit e9bf54aa9c76281557b01439ad7e65be50cb0f3f
Author: linlinnn <li...@163.com>
AuthorDate: Mon Apr 19 22:32:45 2021 +0800
[ISSUE 10153][Go Function] fix time unit ns -> ms (#10160)
Co-authored-by: linjunhua <li...@jiguang.cn>
---
pulsar-function-go/pf/stats.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pulsar-function-go/pf/stats.go b/pulsar-function-go/pf/stats.go
index 8159cac..5aea8b2 100644
--- a/pulsar-function-go/pf/stats.go
+++ b/pulsar-function-go/pf/stats.go
@@ -243,7 +243,7 @@ func (stat *StatWithLabelValues) processTimeEnd() {
if stat.processStartTime != 0 {
now := time.Now()
duration := now.UnixNano() - stat.processStartTime
- stat.statProcessLatencyMs.Observe(float64(duration))
+ stat.statProcessLatencyMs.Observe(float64(duration) / 1e6)
}
}