如何解决Flink指标-指标间隔内的记录数
我们正在使用Flink 1.9.1版本。我们想获取在特定期间内特定子任务处理的记录数。记录数给出了到那时为止的记录总数。有没有一种方法可以获取在该度量标准间隔内处理的记录总数。
解决方法
Flink还注册了一个称为numRecordsOutPerSecond
的度量,它是产生的记录的比率。通过在任何时间间隔内积分该值,您应该能够获得该时间间隔内的速率。
Flink为几种流行的指标系统(例如Prometheus和InfluxDB)提供指标报告器,它们提供了强大的查询引擎,可基于从Flink获得的指标来计算各种聚合统计信息。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。