使用 Flink UI 监控 Flink 作业 - Amazon EMR

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

使用 Flink UI 监控 Flink 作业

要监控正在运行的 Flink 应用程序的运行状况和性能,请使用 Flink Web 控制面板。此控制面板提供有关任务状态、TaskManager 数量以及该任务的指标和日志的信息。借助它还可以查看并修改 Flink 作业配置,以及通过提交或取消作业与 Flink 集群进行交互。

要访问 Kubernetes 上正在运行的 Flink 应用程序的 Flink Web 控制面板,请按照以下步骤操作:

  1. 使用 kubectl port-forward 命令,将本地端口转发到 Flink 应用程序 TaskManager Pod 中运行着 Flink Web 控制面板的端口。默认情况下,此端口为 8081。将 deployment-name 替换为前述 Flink 应用程序部署的名称。

    kubectl get deployments -n namespace

    输出示例:

    kubectl get deployments -n flink-namespace
    NAME                        READY   UP-TO-DATE   AVAILABLE  AGE
    basic-example               1/1       1            1           11m
    flink-kubernetes-operator   1/1       1            1           21h
    kubectl port-forward deployments/deployment-name 8081 -n namespace
  2. 要在本地使用其他端口,请使用 local-port:8081 参数。

    kubectl port-forward -n flink deployments/basic-example 8080:8081
  3. 在 Web 浏览器中导航到 http://localhost:8081(如果使用的是自定义本地端口,则导航到 http://localhost:local-port)来访问 Flink Web 控制面板。此控制面板提供有关正在运行的 Flink 应用程序的信息,例如任务状态、TaskManager 数量以及该任务的指标和日志。

    Flink 控制面板用户界面示例