java - 如何在 Apache Flink ui 中显示指标？

Question

运行 Apache Flink 1.8.0。我可以通过 http://localhost:8081 访问有效的 UI。我还验证了我的工作可以在 IDE 中运行，使用 ./flink run 通过命令行提交。我什至通过用户界面上传了作业。工作进展顺利。

但是当我查看用户界面上的统计数据时，我只看到一个旋转器。示例:接收字节数、接收记录数、发送字节数、发送记录数都有一个微调器。

我也在我的 RichAsyncFunction

UI 文档中没有明确说明，我们是否需要在 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();
}

另外单击“任务指标”我什么也没得到。我无法点击添加指标按钮。

Answer 1

我遇到了同样的问题......但我在 docker swarm 中运行了 flink。

在 flink-config 文件中，我使用主机名作为任务管理器名称。如果更改它并使用任务管理器的 flink 随机名称，指标将再次出现。

另一方面，我读到您可能确定在运行时不使用“分离模式”，因为指标在分离模式下不可用。

希望有帮助