我们使用的是Flink 1.9.1版本。我们希望获得特定期间内由特定子任务处理的记录数。输出的记录数表示到那时为止输出的记录总数。有没有办法获得在该度量间隔内处理的记录总数。
Flink还注册了一个名为numRecordsOutPerSecond的度量，它是生成记录的速率。通过在任何区间内对该值进行积分，您应该能够获得该区间内的速率。
Flink为几个流行的度量系统(如Prometheus和InfluxDB(提供度量报告器，这些系统提供强大的查询引擎，用于根据从Flink获得的度量计算各种聚合统计信息。