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 アプリケーションに関する情報が表示されます。