Потоковые метрики для приложения Flink

Question

Я настроил Flink UI для приложения, работающего в Intellij IDEA. Я хотел бы получить некоторые показатели потоковой передачи, такие как - задержка планирования и время обработки. Тем не менее, я не могу найти нигде в пользовательском интерфейсе. Должна ли быть какая-то конкретная c настройка для этого или я должен явно отправить jar приложения?

В настоящее время Flink UI для задания выглядит следующим образом:

Answer 1

Все метрики задач отображаются в веб-интерфейсе, как упоминал Доминик, но для других областей метрики c (например, метрик заданий) отображаются только некоторые выбранные метрики. Вы можете получить доступ ко всем метрикам через REST API или подключив репортер метрик для отправки метрик во внешнюю систему метрик.

Я не думаю, была предпринята любая попытка измерить задержку планирования, но в метриках работы вы найдете такие вещи, как время перезапуска и время безотказной работы .

Answer 2

В пользовательском интерфейсе у вас должна быть вкладка Task Metrics, когда вы выбираете текущее работающее задание. Эта вкладка позволяет выбрать задачу и просмотреть все доступные метрики. Хотя я не уверен, является ли задержка планирования одной из доступных в настоящее время метрик.

Вероятно, лучшая идея - обратиться, чтобы показать метрики для какого-либо сборщика по вашему выбору. Вы можете найти больше информации в документации: https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/metrics.html.