タスク（またはノード）あたりのフリックスループット

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