lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(executor): 修复指标无法输出

Browse Source
This commit is contained in:
v-zhangjc9
2024-07-30 19:05:43 +08:00
parent 0d2f1ccbb4
commit d8b06e4232
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
utils/executor/src/main/java/com/lanyuanxiaoyao/service/executor/metrics/VictoriaMetricsReporter.java
View File

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