使用InflubDB和Grafana監控Flink

Influxdb和Grafana安裝不在這裏贅述，直接介紹flink的配置。

1、建立InfluxDB數據庫

由於咱們須要將採集的metrics數據保存到influxdb中，因此咱們首先須要建立一個數據庫，create databases flinkonyarn

默認狀況下，influxdb在剛安裝好以後，禁用身份驗證，靜默忽略全部憑據，而且全部用戶都具備全部權限，這樣是極不安全的。在開啓身份驗證以後，建立相應的用戶和對應的密碼

2、配置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;

3、增長Grafana數據源

全部這些弄好後，就能夠配置圖表了。