Как отобразить метрики в Apache Flink UI? - PullRequest
Новая
       16

Как отобразить метрики в Apache Flink UI?

0 голосов
/ 03 мая 2019

работает Apache Flink 1.8.0.Я могу получить доступ к интерфейсу на http://localhost:8081, который работает.Я также проверил, что моя работа работает из среды IDE, отправляя ее из командной строки, используя ./flink run.Я даже загрузил работу через пользовательский интерфейс.Работа отлично работает.

Но когда я смотрю статистику в интерфейсе, я вижу только счетчик.Пример: Получено байтов, Получено записей, Отправлено байтов, Отправлено записей. У всех есть счетчик.

Кроме того, я делаю в своем RichAsyncFunction

Это не ясно в документах для пользовательского интерфейса,Нужно ли нам что-то включать на сервере Flink? 

private transient Counter lookupCounter;
...
@Override
public void open(Configuration parameters) throws Exception {
    super.open(parameters);

    this.lookupCounter = getRuntimeContext()
            .getMetricGroup()
            .addGroup("MyGroup")
            .counter("myCounter");
}

@Override
public void asyncInvoke(String input, ResultFuture<Map<String, Integer>> resultFuture) throws Exception {
    lookupCounter.inc();
}

Также, нажимая на Метрики задач, я ничего не получаю.Я не могу нажать кнопку Add metric.

1 Ответ

0 голосов
/ 06 мая 2019

У меня была такая же проблема ... но я побежал мелькать в рое докеров.

В файле flink-config я использовал имя хоста для имени менеджера задач. Если изменить его и использовать случайные имена для менеджеров задач, метрики появятся снова.

С другой стороны, я читал, что вы можете быть уверены, что не используете «режим отсоединения» при запуске, поскольку метрики недоступны в режиме отсоединения.

Надеюсь, это поможет

...