Flink指标-指标间隔内的记录数

问题描述

我们正在使用Flink 1.9.1版本。我们想获取在特定期间内特定子任务处理的记录数。记录数给出了到那时为止的记录总数。有没有一种方法可以获取在该度量标准间隔内处理的记录总数。

解决方法

Flink还注册了一个称为numRecordsOutPerSecond的度量，它是产生的记录的比率。通过在任何时间间隔内积分该值，您应该能够获得该时间间隔内的速率。

,

Flink为几种流行的指标系统（例如Prometheus和InfluxDB）提供指标报告器，它们提供了强大的查询引擎，可基于从Flink获得的指标来计算各种聚合统计信息。