[fix][function] Fix invalid metric type gauge (apache#18129)

streamnative · Oct 24, 2022 · 39270f0 · 39270f0
1 parent e8db584
commit 39270f0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerStatsManager.java b/...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);