每个任务(或节点)的flink吞吐量

Question

如何计算flink中任务或节点的吞吐量？我可以在Flink文档中找到的吞吐量的唯一引用与仪表有关。但是我不确定这是否可以做我需要的事情。有人可以确认是否可以吗？

Answer 1

在Flink 1.2中，每个任务的吞吐量都会有指标。

在1.1中，您必须自己构建一些东西。您可以使用此FlatMap操作员作为示例来衡量吞吐量：https：//github.com/rmetzger/flink-state-watermarks/blob/master/src/src/main/java/java/com/com/dataartisans/utilils/throughputlogger.java