gpt4 book ai didi

java - Flink webUI 中的 "No Metrics "

转载 作者:太空宇宙 更新时间:2023-11-04 09:38:19 34 4
gpt4 key购买 nike

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

enter image description here

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

最佳答案

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

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

我说的是任务统计信息,但任务指标也错了

关于java - Flink webUI 中的 "No Metrics ",我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56235219/

34 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com