0


Prometheus之集成Flink

目录

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集成成功

验证集成


本文转载自: https://blog.csdn.net/yy8623977/article/details/125318526
版权归原作者 Bulut0907 所有, 如有侵权,请联系我们删除。

“Prometheus之集成Flink”的评论:

还没有评论