flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hb <343122...@163.com>
Subject flink1.9.1 Metrics 上报 PrometheusPushGateway问题
Date Wed, 11 Dec 2019 02:40:24 GMT
flink-1.9.1/lib 目录下已有  flink-metrics-prometheus_2.11-1.9.1.jar.
PrometheusPushGateway 能收到flink上报的metrics.
但是 JobManager 日志一直报异常
2019-12-0316:37:36,094WARN org.apache.flink.metrics.prometheus.PrometheusPushGatewayReporter
- Failed to push metrics to PushGateway with jobName flinkJob881bd99bbdcd622f3567c36f1602c4dc.
java.io.IOException: Response code from http://192.168.102.77:9091/metrics/job/flinkJob881bd99bbdcd622f3567c36f1602c4dc
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:105)
    at org.apache.flink.metrics.prometheus.PrometheusPushGatewayReporter.report(PrometheusPushGatewayReporter.java:76)
    at org.apache.flink.runtime.metrics.MetricRegistryImpl$ReporterTask.run(MetricRegistryImpl.java:436)
    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:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)


每隔10秒上报一次metrics,10秒产生一次异常,
我看源码说是 http code = 202 不报异常,这里 Response code 是200

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message