Use UTF-8 for pushing metrics to Prometheus

Author: kupferk

AUTHORS

@@ -3,3 +3,4 @@ The following people have contributed to Flowman and are referred to as "The Flo
 * Kaya Kupferschmidt <[email protected]>
 * Siegfried Weber <[email protected]>
 * Jacek Kmiecik
+* Lukas Senicourt

CHANGELOG.md

@@ -18,6 +18,12 @@ Breaking changes will be documented in this changelog file for each version.
 
 # Changelog
 
+## Version 1.3.2
+
+* Fix documentation of SQL mapping
+*  
+
+
 ## Version 1.3.1 - 2024-12-19
 
 * github-514: Generated SQL code for views should quote all column names

flowman-spec/src/main/scala/com/dimajix/flowman/spec/metric/PrometheusMetricSink.scala

@@ -18,10 +18,12 @@ package com.dimajix.flowman.spec.metric
 
 import java.io.IOException
 import java.net.URI
+import java.nio.charset.Charset
 
 import scala.util.control.NonFatal
 
 import com.fasterxml.jackson.annotation.JsonProperty
+import org.apache.http.Consts
 import org.apache.http.HttpResponse
 import org.apache.http.client.HttpResponseException
 import org.apache.http.client.ResponseHandler
@@ -90,9 +92,9 @@ extends AbstractMetricSink with Logging {
 
         val httpClient = HttpClients.createDefault()
         try {
-            val httpPost = new HttpPut(url)
-            httpPost.setEntity(new StringEntity(payload))
-            httpClient.execute(httpPost, handler)
+            val httpPut = new HttpPut(url)
+            httpPut.setEntity(new StringEntity(payload, Consts.UTF_8))
+            httpClient.execute(httpPut, handler)
         }
         catch {
             case ex:HttpResponseException =>