我启动了一个本地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 板上显示的指标?
1条答案
按热度按时间iswrvxsc1#
我也有同样的问题。我的问题是在集群配置中,我使用主机名来命名taskmanager,当我更改它(使用默认名称)时,任务度量开始工作。我使用docker swarm部署flink集群。
这是我的问题flink 1.7.0 Jmeter 板不显示任务统计信息
我说的是任务统计数据,但taskmetrics也错了