运行ApacheFlink1.8.0。我可以访问 http://localhost:8081
这很管用。我还验证了我的工作是在ide上进行的,通过命令行使用 ./flink run
. 我甚至通过用户界面上传了这份工作。这工作做得很好。
但是当我查看ui上的统计信息时,我只看到一个微调器。示例:bytes receives、records received、bytes sent、records sent都有一个微调器。
我也在做我的工作 RichAsyncFunction
在用户界面的文档中不清楚,我们需要在flink服务器上启用一些东西吗?
private transient Counter lookupCounter;
@Override
public void open(Configuration parameters) throws Exception {
super.open(parameters);
this.lookupCounter = getRuntimeContext()
.getMetricGroup()
.addGroup("MyGroup")
.counter("myCounter");
}
@Override
public void asyncInvoke(String input, ResultFuture<Map<String, Integer>> resultFuture) throws Exception {
lookupCounter.inc();
}
同时点击任务指标,我什么也得不到。我不能点击 Add metric
按钮。
1条答案
按热度按时间dhxwm5r41#
我也有同样的问题。。。但我在 Docker 群里找到了Flink。
在flink配置文件中,我使用主机名作为任务管理器的名称。如果我更改了它并使用flink随机名称作为任务管理器,那么度量值会再次出现。
另一方面,我读到您可以确定在运行时不使用“分离模式”,因为这些度量在分离模式下不可用。
我希望这有帮助