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


0

如何计算Flink中任务或节点的吞吐量?在Flink的文档中,我能找到的关于吞吐量的唯一参考是关于Meter的。但我不确定这是否符合我的需要。有人能确认一下吗?

1 答案


0

在Flink1.2中,将有每个任务的吞吐量指标。

在1.1中,你必须自己构建一些东西。您可以使用此flatMap运算符作为示例来测量吞吐量:https://github.com/rmetzger/flink-state-watermarks/blob/master/src/main/java/com/dataartisans/utils/ThroughputLogger.java


我来回答

写文章

提问题

面试题