#apache-flink #dashboard #metrics
#apache-flink #Информационная панель #показатели
Вопрос:
У меня есть два оператора, источник и карта. Входящая пропускная способность карты застряла на уровне чуть выше 6 тыс. сообщений / с, тогда как количество сообщений достигает размера всего потока (~ 350 тыс.) менее чем за 20 секунд (см. Длительность). 350000/20 означает, что у меня пропускная способность не менее 17500, а не 6000, как предполагает flink! Что здесь происходит?
как показано на рисунке:
время начала = 13:10:29
все сообщения уже прочитаны = 13:10:46 (менее 20 секунд)
Ответ №1:
Я проверил код библиотеки flink, и кажется, что статистика numRecordsOutPerSecond (а также остальные аналогичные) работают в окне. Это означает, что они отображают среднюю пропускную способность, но за последние X секунд. Это не средняя пропускная способность всего выполнения