Скорость перехода на одну задачу (или узел)

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