"Нет метрик" в веб-интерфейсе Flink - PullRequest
Новая
       38

"Нет метрик" в веб-интерфейсе Flink

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

Я запустил локальный сервер Flink (./bin/start-cluster.sh) и отправил задание.У меня есть следующий код для определения метрики.

.map(new RichMapFunction<String, String>() {
        private transient Counter counter;

        @Override
        public void open(Configuration config) {
            this.counter = getRuntimeContext()
                    .getMetricGroup()
                    .counter("myCounter");
        }

        @Override
        public String map(String value) throws Exception {
            this.counter.inc();
            return value;
        }
    })

но когда я запускаю задание и отправляю некоторые данные, я не вижу никаких метрик в веб-интерфейсе Flink, просто «Нет метрик»

enter image description here

Я настроил репортер JMX в файле flink-conf.yaml.Я не уверен, как я могу получить показатели, показанные на приборной панели?

1 Ответ

1 голос
/ 21 мая 2019

У меня была такая же проблема. Моя проблема была в конфигурации кластера, я использовал имя хоста для имени менеджера задач, и когда я меняю его (используя имя по умолчанию), метрики задач начинают работать. Я использую docker-swarm для развертывания кластера flink.

Это мой вопрос Flink 1.7.0 На панели инструментов не отображается статистика задач

Я говорил о статистике задач, но метрика задачи тоже была неправильной

...