使用 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 應用程式 TaskManager Pod 中執行 Flink Web Dashboard 的連接埠。此連接埠預設為 8081。Replace (取代) 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 範例