From 55dbe86ab1a608d9e9546c74c56a2b22184d246a Mon Sep 17 00:00:00 2001
From: coderzc <zhaocong@apache.org>
Date: Thu, 20 Oct 2022 11:43:45 +0800
Subject: [PATCH] fix invalid metric type "gauge "

---
 .../org/apache/pulsar/functions/worker/WorkerStatsManager.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 c9b7c1da8db44..4c7d28cc70d84 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
@@ -329,7 +329,8 @@ 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 \n");
+    stream.write(" gauge");
+    stream.write("\n");
 
     stream.write(PULSAR_FUNCTION_WORKER_METRICS_PREFIX);
     stream.write(metricName);