Apache Flink: пользовательский идентификатор для метрик задачи flink

TheEliteOne спросил: 28 марта 2018 в 02:50 в: apache-flink

Я хотел бы отредактировать идентификатор метрик задачи на flink, поэтому я могу сделать некоторые показатели в Java Mission Control с помощью JMX. Причина, по которой вы хотите сначала ее отредактировать, - это потому, что я хочу, чтобы было легче найти на JMCCan кто-нибудь поможет мне решить эту проблему?


1 ответ

David ответил: 30 марта 2018 в 03:07

Вы не можете изменить этот идентификатор в веб-интерфейсе, как он есть на веб-сервере среды выполнения.

Если вы подключаетесь к Flink JMXReport для получения метрик, вы можете использовать task name чтобы отфильтровать нужные данные, так как данные из JMX содержат task name, task id и т. д.

Другой способ - реализовать собственный репортер метрик, только в том числе имя задачи в нем. Так что четче получить метрики из JMX.

TheEliteOne ответил: 31 марта 2018 в 06:07
Есть ли учебник по созданию собственного репортера метрики? это будет использовать JMXReporter?
David ответил: 01 апреля 2018 в 09:16
Пожалуйста, обратитесь к исходному коду https://github.com/apache/flink/blob/master/flink-metrics/flink-metrics-jmx/src/main/java/org/apache/flink/metrics/jmx/JMXReporter.java. Если вы хотите реализовать один, вам нужно только реализовать интерфейс MetricReporter. Обновите функцию с именем generateJmxTable, чтобы упростить имя объекта из JMX.