Flink config custom jar reporter для yaml, и подключите хост через консоль JMX

Question

Я учусь, и мне нужна помощь, пожалуйста.

У меня есть проект Java maven, который реализует интерфейс Flink MetricsReporter , как мой собственный репортер для отправки метрик.

В моем локальном Flink я смог:

1. Добавить Конфигурация Flink JMX Reporter в локальном файле flink-conf.yaml.
2. Начните мигать на порте 8789
3. Используйте JConsole (консоль JMX) для подключения к удаленному локальному хосту: 8789
4. Перезапустите flink, см. Метрики мигания в Janssole Beans.

После этого подтверждения концепции того, что рабочий процесс работает, я хочу сделать следующее:

1. Я написал собственный репортер, реализующий интерфейс metrics , и создалрепортер в банку со всеми необходимыми зависимостями.
2. Я переместил банку в папку flink lib/, как предложено из Важный абзац документации Reporter

Моя банка названа x-y-reporter-1.0-SNAPSHOT.jar Пом

  <groupId>a.b.c</groupId>
  <artifactId>x-y-reporter</artifactId>
  <version>1.0-SNAPSHOT</version>

Я обновил конфигурацию ниже, чтобы flink-conf.yaml

metrics.reporters: x-y-reporter
metrics.reporter.x-y-reporter.class: com.b.c.xyreporter.XYReporter
metrics.reporter.x-y-reporter.class.host: localhost
metrics.reporter.x-y-reporter.port: 8789

Вопрос:

• Я хочу заменить JMX-конфиги на свои собственные репортерские конфиги в flink-conf.yaml.Вышеуказанный конфиг не работает.Как бы я это сделал, пожалуйста?Что означает каждый параметр, пожалуйста?
• Я хочу видеть метрики из консоли JMX, такие как JMX-репортер.Это тоже через настройку через номер порта?

Спасибо большое.

Answer 1

Проверял логи флинка после перезапуска флинка с настройкой в ​​вопросе.Оказывается, в моем пользовательском классе есть ошибка.После исправления ошибки и подключения к локальному процессу apache-flink в JConsole я вижу класс в списках MBean.Мне не нужно подключаться к удаленному или локальному хосту.