码迷,mamicode.com
首页 > 数据库 > 详细

使用InflubDB和Grafana监控Flink

时间:2019-10-12 19:10:13      阅读:276      评论:0      收藏:0      [点我收藏+]

标签:cat   idt   comment   固定   yaml   数据源   global   oca   name   

Influxdb和Grafana安装不在这里赘述,直接介绍flink的配置。

一、创建InfluxDB数据库

因为我们需要将采集的metrics数据保存到influxdb中,所以我们首先需要创建一个数据库,create databases flinkonyarn

默认情况下,influxdb在刚安装好之后,禁用身份验证,静默忽略所有凭据,并且所有用户都具有所有权限,这样是极不安全的。在开启身份验证之后,创建相应的用户和对应的密码

二、配置flink文件

修改配置文件 conf/flink-conf.yaml 在最后面增加以下

metrics.reporter.influxdb.class: org.apache.flink.metrics.influxdb.InfluxdbReporter
metrics.reporter.influxdb.host: xx.xx.xx.xx
metrics.reporter.influxdb.port: 8086
metrics.reporter.influxdb.db: flinkonyarn
metrics.reporter.influxdb.username: admin
metrics.reporter.influxdb.password: admin

class:这个是固定的 
host:这个是安装 InfluxDB 的 host 地址 
port:这个是 InfluxDB 的端?口,默认是 8086 
db:表示你要将 metrics 数据存?入到 InfluxDB 的哪个数据库 
username:InfluxDB 的?用户名 
password:InfluxDB 的密码

配置完以上两步,新提交的flink任务产生的metrics数据就会写入到influxdb中,我们可以看有没有对应的表产生

use flinkonyarn

show measurements

技术图片

查看表数据 select * from jobmanager_Status_JVM_CPU_Load limit 10;

技术图片

三、增加Grafana数据源

技术图片

所有这些弄好后,就可以配置图表了。

技术图片

 

 技术图片

 

使用InflubDB和Grafana监控Flink

标签:cat   idt   comment   固定   yaml   数据源   global   oca   name   

原文地址:https://www.cnblogs.com/createweb/p/11636762.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!