From d8b06e4232a7c76646c1147a095752674c8265ea Mon Sep 17 00:00:00 2001
From: v-zhangjc9 <v-zhangjc9.gd@chinatelecom.cn>
Date: Tue, 30 Jul 2024 19:05:43 +0800
Subject: [PATCH] =?UTF-8?q?fix(executor):=20=E4=BF=AE=E5=A4=8D=E6=8C=87?=
 =?UTF-8?q?=E6=A0=87=E6=97=A0=E6=B3=95=E8=BE=93=E5=87=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/executor/metrics/VictoriaMetricsReporter.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/utils/executor/src/main/java/com/lanyuanxiaoyao/service/executor/metrics/VictoriaMetricsReporter.java b/utils/executor/src/main/java/com/lanyuanxiaoyao/service/executor/metrics/VictoriaMetricsReporter.java
index 61b4e04..8d472e0 100644
--- a/utils/executor/src/main/java/com/lanyuanxiaoyao/service/executor/metrics/VictoriaMetricsReporter.java
+++ b/utils/executor/src/main/java/com/lanyuanxiaoyao/service/executor/metrics/VictoriaMetricsReporter.java
@@ -7,7 +7,6 @@ import java.io.StringWriter;
 import java.util.Map;
 import java.util.stream.Collectors;
 import org.apache.flink.metrics.prometheus.AbstractPrometheusReporter;
-import org.apache.flink.metrics.reporter.InstantiateViaFactory;
 import org.apache.flink.metrics.reporter.Scheduled;
 import org.apache.flink.shaded.hadoop2.org.apache.http.HttpEntity;
 import org.apache.flink.shaded.hadoop2.org.apache.http.HttpResponse;
@@ -16,6 +15,7 @@ import org.apache.flink.shaded.hadoop2.org.apache.http.auth.UsernamePasswordCred
 import org.apache.flink.shaded.hadoop2.org.apache.http.client.CredentialsProvider;
 import org.apache.flink.shaded.hadoop2.org.apache.http.client.config.RequestConfig;
 import org.apache.flink.shaded.hadoop2.org.apache.http.client.methods.HttpPost;
+import org.apache.flink.shaded.hadoop2.org.apache.http.entity.StringEntity;
 import org.apache.flink.shaded.hadoop2.org.apache.http.impl.client.BasicCredentialsProvider;
 import org.apache.flink.shaded.hadoop2.org.apache.http.impl.client.CloseableHttpClient;
 import org.apache.flink.shaded.hadoop2.org.apache.http.impl.client.HttpClientBuilder;
@@ -27,7 +27,6 @@ import org.slf4j.LoggerFactory;
  * @author ZhangJiacheng
  * @date 2022-06-22
  */
-@InstantiateViaFactory(factoryClassName = "com.lanyuanxiaoyao.service.executor.metrics.VictoriaMetricsReporterFactory")
 public class VictoriaMetricsReporter extends AbstractPrometheusReporter implements Scheduled {
     private static final Logger logger = LoggerFactory.getLogger(VictoriaMetricsReporter.class);
 
@@ -71,6 +70,7 @@ public class VictoriaMetricsReporter extends AbstractPrometheusReporter implemen
             try (CloseableHttpClient client = builder.build()) {
                 HttpPost post = new HttpPost(String.format("%s?%s", endpoint, query));
                 post.setConfig(requestConfig);
+                post.setEntity(new StringEntity(writer.toString()));
                 HttpResponse response = client.execute(post);
                 int code = response.getStatusLine().getStatusCode();
                 if (code < 200 || code >= 300) {