如何在ApacheFlinkUI中显示度量?

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

运行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 按钮。

dhxwm5r4

dhxwm5r41#

我也有同样的问题。。。但我在 Docker 群里找到了Flink。
在flink配置文件中,我使用主机名作为任务管理器的名称。如果我更改了它并使用flink随机名称作为任务管理器,那么度量值会再次出现。
另一方面,我读到您可以确定在运行时不使用“分离模式”,因为这些度量在分离模式下不可用。
我希望这有帮助

相关问题