前言

虽然博主之前写过基于Prometheus PushGateway搭建Flink监控的过程,但是在我们的生产环境中,使用的是InfluxDB。InfluxDB是一个由Go语言写成的、由InfluxData部分开源的时序数据库,能够非常好地处理监控指标的存储和查询,配合Grafana即可简单地实现Flink作业metrics的收集与展示。本文简述配置过程及一些小问题。

硬件参数

新版InfluxDB的集群版是收费的,但是单点也足够我们存储较长时间的监控数据了。

  • CPU:Intel E5 v4 12C/24T

  • 内存:96GB

  • 硬盘:500GB SSD * 2

  • 网络:10Gbps

  • 操作系统:CentOS 7.5 64-bit

  • InfluxDB 1.8

  • Grafana 6.7.4

安装与配置InfluxDB

先下载RPM包,再用yum localinstall安装,可以自动解决依赖关系。

wget https://dl.influxdata.com/influxdb/releases/influxdb-1.8.0.x86_64.rpm
yum -y localinstall influxdb-1.8.0.x86_64.rpm

安装完毕后,配置文件位于/etc/influxdb/influxdb.conf。具体配置项可参见官方文档,有一些需要注意的,列举如下。

  • 元数据存储目录

Flink从入门到精通100篇(三)-如何利用InfluxDB+Grafana搭建Flink on YARN作业监控大屏环境相关推荐

  1. Flink从入门到精通100篇(二十三)-基于Apache Flink的爱奇艺实时计算平台建设实践

    前言 随着大数据的快速发展,行业大数据服务越来越重要.同时,对大数据实时计算的要求也越来越高.今天会和大家分享下爱奇艺基于Apache Flink的实时计算平台建设实践. 今天的介绍会围绕下面三点展开 ...

  2. Flink从入门到精通100篇(二十四)-对Flink SQL Client 源码做深度解析

    前言 本文基于 Flink 1.12-SNAPSHOT,使用sql client命令行提交insert语句进行整个流程的分析. sql-client.sh embedded --update &quo ...

  3. Flink从入门到精通100篇(二十二)-Apache Flink OLAP引擎性能优化及应用

    前言 本次分享的主题为Apache Flink新场景--OLAP引擎,主要内容包括: 背景介绍 Apache Flink OLAP引擎 案例介绍 未来计划 1. OLAP及其分类 OLAP是一种让用户 ...

  4. influxdb tsm文件_利用InfluxDB+Grafana搭建Flink on YARN作业监控大屏

    Flink 从入门到精通 系列文章 前言 虽然笔者之前写过基于Prometheus PushGateway搭建Flink监控的过程,但是在我们的生产环境中,使用的是InfluxDB.InfluxDB是 ...

  5. Flink从入门到精通100篇(二十一)-万字长文详解 Flink 中的 CopyOnWriteStateTable

    前言 现如今想阅读 HashMap 源码实际上比较简单,因为网上一大堆博客去分析 HashMap 和 ConcurrentHashMap.本文详细分析 CopyOnWriteStateTable 源码 ...

  6. Flink从入门到精通100篇(二十)-跨境电商 Shopee 的实时数仓之路

    前言 本文讲述 Flink 在 Shopee 新加坡数据组 ( Shopee Singapore Data Team ) 的应用实践,主要内容包括: 实时数仓建设背景 Flink 在实时数据数仓建设中 ...

  7. Flink从入门到精通100篇(十三)-Flink的入门教学

    前言 Flink 是一种流式计算框架,为什么我会接触到 Flink 呢?因为我目前在负责的是监控平台的告警部分,负责采集到的监控数据会直接往 kafka 里塞,然后告警这边需要从 kafka topi ...

  8. Flink从入门到精通100篇(二十一)-Apache Flink 与 Apache Hive 的集成

    前言 随着 Flink 在流式计算的应用场景逐渐成熟和流行.如果 Flink 能同时把批量计算的应用场景处理好,就能减少用户在使用 Flink 的开发和维护成本,并且能够丰富 Flink 的生态.因为 ...

  9. Flink从入门到精通100篇(二十三)-Flink实战应用案例:如何清理过期的 Checkpoint 目录?

    目录 Flink Checkpoint 目录的清除策略 生产环境应该选择哪种清除策略 生产环境必须定期脚本清理 Checkpoint 和 Savepoint 目录 RocksDB 增量 Checkpo ...

最新文章

  1. 7.STM32中对DMA_Config()函数的理解(自定义)测试DMA传输数据时CPU还可继续工作其他的事
  2. 关于Git的几个使用技巧
  3. linux5.5 dvd安装教程,linux 5.5 yum的安装方法(ftp)
  4. JavA持有类_关于继承:Java持有对象的超类的类型
  5. 创建一个Hello World的Confluence宏
  6. centos mysql php tomcat_CentOS 6.x使用yum快速安装Apache+PHP+Tomcat(JSP)+MySQL
  7. [Perforce]password (P4PASSWD) invalid or unset. 的错误解决
  8. C#净化版WebApi框架
  9. 自己制作的ORMap框架终于完成的差不多了。
  10. 百度区块链 xuperchain 节点端 tps统计脚本
  11. 【优化求解】基于matlab改进的粒子群算法求解混合储能系统容量优化问题【含Matlab源码 1823期】
  12. Linux 图片批量压缩工具
  13. 使用ARCGIS对shp数据添加投影坐标系
  14. 万能平板刷机软件_万能手机刷机软件下载
  15. mysql错误代码1813_MSSQL2000数据库附加错误1813解决方案
  16. 聚合数据--汇率接口调用
  17. 线性回归:自相关检测及其处理方法
  18. Hbuilder 真机运行显示未受信任的解决方法(ios)
  19. php后门检测工具,phpStudy后门如何检测和修复
  20. HarmonyOS内存占用,华为HarmonyOS对比EMUI11:内存占用更少 系统更流畅

热门文章

  1. 陶哲轩实分析习题17.1.2
  2. wifi网络结构(上)
  3. PAT甲级1049 Counting Ones (30 分):[C++题解]统计1的个数、数位统计
  4. PAT甲级1001 A+B Format:[C++题解]字符串处理
  5. dell 如何给raid分区_什么是RAID技术?
  6. Leetcode 70. 爬楼梯 动态规划 c语言
  7. 软件界面中英文对照_再也不用翻译软件了,弱电行业术语大全及中英文对照表来了~...
  8. tkinter回调异常_处理python tkinter中的异常
  9. php事件和行为,Yii框架组件和事件行为管理详解
  10. python数字和运算_Python学习笔记:数字类型和运算符,与