每个任务（或节点）的Flink吞吐量

Question

如何计算Flink中任务或节点的吞吐量？我能在Flink的文档中找到的吞吐量的唯一参考与Meter有关。但我不确定这是否符合我的需求。有人可以确认它吗？

Answer 1

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

在1.1中，你必须自己构建一些东西。你可以使用这个flatMap操作符来测量吞吐量：https://github.com/rmetzger/flink-state-watermarks/blob/master/src/main/java/com/dataartisans/utils/ThroughputLogger.java