我有一个使用flink（1.9）的程序，我想在 Jmeter 板的帮助下检查map操作符示例的吞吐量。从已经存在的指标来看，numrecordsinpersecond似乎是最有希望的，但我猜它不涉及处理时间。我错了吗？
我已经定义了自己的度量（吞吐量），它通过将处理的记录数除以out map（in value）函数的总执行时间来计算平均吞吐量。但这并不包括map函数之外发生的任何事情。
另一个想法是在map函数的末尾添加一个meter，但是我认为如果源代码不能足够快地生成记录，那么计算的吞吐量会更差，因为操作符在很多时候都是空闲的。是这样吗？
请具体回答1和2。另外，您通常如何计算程序中的吞吐量？
1条答案
按热度按时间nkoocmlb1#
flink的所有度量指标，比如numrecordsinpersecond，都是以处理时间来度量速率的。
我通常满足于依靠这些内置指标来衡量吞吐量。但是您可能需要在sink中添加一个自定义度量，因为flink总是为numrecordsout返回0，为sinks返回numrecordsoutpersecond。