使用 PrometheusPushGateway 报告 flink 指标时从 prometheus 获取代码 '200'答案

【问题标题】：Get code '200' from prometheus when using PrometheusPushGateway to report flink metrics使用 PrometheusPushGateway 报告 flink 指标时从 prometheus 获取代码 '200'
【发布时间】：2020-05-06 07:24:16
【问题描述】：

当我使用 flink-metrics-prometheus_2.11-1.10.0.jar 向 prometheus 报告指标时，出现以下错误，我想知道这个问题的原因以及我该如何解决：

    2020-04-20 15:32:17.940 [Flink-MetricRegistry-thread-1] WARN  org.apache.flink.metrics.prometheus.PrometheusPushGatewayReporter  - Failed to push metrics to PushGateway with jobName oceanus, groupingKey {}.
java.io.IOException: Response code from http://9.91.161.72:80/metrics/job/oceanus was 200
        at org.apache.flink.shaded.io.prometheus.client.exporter.PushGateway.doRequest(PushGateway.java:297)
        at org.apache.flink.shaded.io.prometheus.client.exporter.PushGateway.push(PushGateway.java:127)
        at org.apache.flink.metrics.prometheus.PrometheusPushGatewayReporter.report(PrometheusPushGatewayReporter.java:109)
        at org.apache.flink.runtime.metrics.MetricRegistryImpl$ReporterTask.run(MetricRegistryImpl.java:441)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)

【问题讨论】：

标签： apache-flink prometheus metrics flink-streaming prometheus-java

【解决方案1】：

how responses are handled 似乎最近发生了变化。

我怀疑您需要将 prometheus jar 与服务器版本匹配，反之亦然。

【讨论】：

【解决方案2】：

似乎 flink-metrics-prometheus-1.10.0.jar 包含一个非常旧的 prometheus 客户端 java 版本（https://github.com/apache/flink/blob/master/flink-metrics/flink-metrics-prometheus/pom.xml#L79，https://github.com/apache/flink/blob/release-1.9.1/pom.xml#L125 - 0.3.0 版本）。

“200 OK”响应代码上令人讨厌的 WARN 已修复为 0.8.0 (https://github.com/prometheus/client_java/blob/parent-0.8.0/simpleclient_pushgateway/src/main/java/io/prometheus/client/exporter/PushGateway.java#L316)。该版本自 Flink 1.11.0 (https://github.com/apache/flink/blob/release-1.11.0/pom.xml#L127) 起包含在内。

因此解决方案是将 flink-metrics-prometheus-1.11.0.jar 作为类路径的一部分。

不用担心那里的 Flink 版本不兼容，因为我使用的是 Flink 1.9.1 和 flink-metrics-prometheus-1.11.0.jar 并且一切正常。我想 Flink 版本之间的那部分没有太多变化

【讨论】：