每個任務（或節點）的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