[pulsar] branch branch-2.10 updated: [fix][function] Fix invalid metric type `gauge ` (#18129)

[xiangying]

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

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


The following commit(s) were added to refs/heads/branch-2.10 by this push:
     new c5d43553673 [fix][function] Fix invalid metric type `gauge ` (#18129)
c5d43553673 is described below

commit c5d43553673a3f7c01567e92291f0c6497a1fb63
Author: Cong Zhao <zhaoc...@apache.org>
AuthorDate: Mon Oct 24 13:11:24 2022 +0800

    [fix][function] Fix invalid metric type `gauge ` (#18129)
    
    (cherry picked from commit 39270f0439aeb73d65e90dac999a7cfcfbc257ab)
---
 .../java/org/apache/pulsar/functions/worker/WorkerStatsManager.java | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerStatsManager.java
 
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerStatsManager.java
index c8b411cbf57..0076a2f20e9 100644
--- 
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerStatsManager.java
+++ 
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerStatsManager.java
@@ -328,6 +328,12 @@ public class WorkerStatsManager {
   }
 
   private void writeMetric(String metricName, long value, StringWriter stream) 
{
+    stream.write("# TYPE ");
+    stream.write(PULSAR_FUNCTION_WORKER_METRICS_PREFIX);
+    stream.write(metricName);
+    stream.write(" gauge");
+    stream.write("\n");
+
     stream.write(PULSAR_FUNCTION_WORKER_METRICS_PREFIX);
     stream.write(metricName);
     stream.write("{");