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) {