【发布时间】：2016-12-05 17:13:50
【问题描述】：
如何计算 Flink 中任务或节点的吞吐量？我可以在 Flink 的文档中找到的对吞吐量的唯一参考与 Meter 有关。但我不确定这是否符合我的需要。有人可以确认吗？
【问题讨论】：
标签： apache-flink
【发布时间】：2016-12-05 17:13:50
【问题描述】：
在 Flink 1.2 中，每个任务的吞吐量都有指标。
在 1.1 中，您必须自己构建一些东西。您可以使用这个 flatMap 运算符作为示例来测量吞吐量：https://github.com/rmetzger/flink-state-watermarks/blob/master/src/main/java/com/dataartisans/utils/ThroughputLogger.java
【讨论】：
-
谢谢！我实际上要瞄准 1.2，所以这是个好消息