"No Metrics " 一个 Flink webUI

Question

我启动了一个本地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 web UI 中看不到任何指标，只是 "No metrics"

我已经在 flink-conf.yaml 中配置了 JMX 报告器。我不确定如何获得仪表板上显示的指标？

Answer 1

我遇到了同样的问题。我的问题出在集群配置中，我使用主机名来命名任务管理器，当我更改它（使用默认名称）时，任务指标开始工作。我使用docker-swarm部署flink集群

这是我的问题 Flink 1.7.0 Dashboard not show Task Statistics

我说的是任务统计，但任务指标也不对

"No Metrics " 一个 Flink webUI

"No Metrics " in Flink webUI

java

metrics

apache-flink

flink-streaming