Flink支持Source和Sink算子数据统计指标

使用场景

Flink提供了监控指标（Metrics）来帮助分析作业，该特性新增Source、Sink算子统计指标到Metrics系统中，默认开启，无需配置。便于直接观察Source、Sink算子的数据收发情况，可在Flink的原生Web UI界面查看。

约束与限制

本章节适用于MRS 3.6.0-LTS.1及之后的版本。

配置步骤

1. 作业成功运行后，单击“操作”列的“作业详情”进入Flink的原生Web UI界面。
2. 在“Running Jobs”界面，单击任务名称，查看Source、Sink算子数据统计指标，如：
   • “0.Source__datagen[1].source.numRecordsIn/numRecordsInPerSecond/numRecordsOut/numRecordsOutPerSecond”用于统计Source算子已接收/发送的记录总数和速度（条/秒）。
   • “0.Sink__fs_table[3].sink.numRecordsIn/numRecordsInPerSecond/numRecordsOut/numRecordsOutPerSecond”用于统计Sink算子已接收/发送的记录总数和速度（条/秒）。