java——flink webui中的“无指标”

f8rj6qna  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(537)

我启动了一个本地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中看不到任何度量,只是“没有度量”

我已经在flink-conf.yaml中配置了jmx reporter。我不知道如何才能得到 Jmeter 板上显示的指标?

iswrvxsc

iswrvxsc1#

我也有同样的问题。我的问题是在集群配置中,我使用主机名来命名taskmanager,当我更改它(使用默认名称)时,任务度量开始工作。我使用docker swarm部署flink集群。
这是我的问题flink 1.7.0 Jmeter 板不显示任务统计信息
我说的是任务统计数据,但taskmetrics也错了

相关问题