使用 Flink UI 监控 Flink 任务 - Amazon EMR
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

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

使用 Flink UI 监控 Flink 任务

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

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

  1. 使用kubectl port-forward命令将本地端口转发到 Flink 应用程序容器中运行 Flink Web 控制面板的 TaskManager 端口。默认情况下,此端口为 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 应用程序的信息,例如作业的状态 TaskManagers、数量以及该作业的指标和日志。

    Flink 控制面板用户界面示例