使用 Flink UI 監控 Flink 作業 - Amazon EMR

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

使用 Flink UI 監控 Flink 作業

若要監控執行中 Flink 應用程式的運作狀態和效能,請使用 Flink Web Dashboard。此儀表板提供有關工作狀態、數量 TaskManagers以及工作指標和記錄的資訊。它也可讓您檢視和修改 Flink 作業的組態,並與 Flink 叢集互動,以提交或取消作業。

若要存取正在 Kubernetes 上執行的 Flink 應用程式的 Flink Web Dashboard,請執行下列動作:

  1. 使用此kubectl port-forward命令將本機連接埠轉寄至 Flink Web 儀表板在 Flink 應用程式網繭中執行的 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. 在網頁瀏覽器中,導覽至 http://localhost:8081 (或 http://localhost:local-port,如果您使用自訂本機連接埠) 以存取 Flink Web Dashboard。此儀表板會顯示執行中 Flink 應用程式的相關資訊,例如工作狀態 TaskManagers、數量以及工作的指標和記錄。

    Flink 儀表板 UI 範例