1. 基本介绍

Flink提供的Metrics可以在Flink内部收集一些指标，通过这些指标让开发人员更
好地查看作业或集群的状态

2. 拷贝Flink jar包

在Flink集群所有服务器执行如下操作

[root@bigdata001 flink-1.14.4]# pwd
/opt/flink-1.14.4
[root@bigdata001 flink-1.14.4]# 
[root@bigdata001 flink-1.14.4]# cp plugins/metrics-prometheus/flink-metrics-prometheus-1.14.4.jar lib/
[root@bigdata001 flink-1.14.4]# 

3. 修改Flink的配置文件flink-conf.yaml

向Flink集群所有服务器的conf/flink-conf.yaml添加如下内容

metrics.reporter.promgateway.class: org.apache.flink.metrics.prometheus.PrometheusPushGatewayReporter
# PushGateway的host和port
metrics.reporter.promgateway.host: bigdata001
metrics.reporter.promgateway.port: 9091
# Flink metric在前端展示的标签(前缀)
metrics.reporter.promgateway.jobName: flink-cluster-metrics
# 是否在Flink metric的标签添加随机后缀
metrics.reporter.promgateway.randomJobNameSuffix: true
# Flink集群关闭时，是否删除Pushgateway中的Flink metrics
metrics.reporter.promgateway.deleteOnShutdown: false
# Flink向Pushgateway推送metrics的时间间隔
metrics.reporter.promgateway.interval: 60 SECONDS

4. 重启Flink集群

5. 验证是否集成成功

在Prometheus的输入框中输入flink，出现如下提示，说明Flink和Prometheus集成成功