Flink / Scala - Metrics 使用与详解

一.引言

Flink 公开了一套度量系统，允许开发者收集运行中的数据并展示到外部系统，例如终端和监控页面，1.15.x 下 Flink 支持四套监控指标：

• A.Counter - 计数器，针对最基本的计数需求，类似 Accumulator 累加器
• B.Gauges - 仪表，针对自定义 T 的累加需求，结果通过 T.toString() 展示
• C.Histograms - 直方图，针对数值型数据统计直方图并在监控页面展示
• D.Meters - 计量 - 通过 mark 的标点方式并进行时间粒度的流量统计

用户可以在调用扩展 RichFunction 的任何用户自定义函数中调用

getRuntimeContext().getMetricGroup()

该方法会返回一个 MetricGroup 对象，其类似于 Map，通过用户自定义 String 索引用户自定义的 metric 指标，下面介绍几种 metric 指标的使用方法。

二.准备工作

1.测试 Source 逻辑

下述 demo 均使用下述数据源，该数据源继承 RichSourceFunction，从 start = 0 开始，每5s生产100 个连续数据并累加 start，循环往复。