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 ポッドで Flink Web Dashboard が実行されているポートにローカルポートを転送します。デフォルトでは、このポートは 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 にアクセスします。ジョブのステータス、TaskManagers の数、ジョブのメトリクスとログといった実行中の Flink アプリケーションの情報を確認できます。

    Flink Dashboard の UI の例