EMR on ACK で Flink ジョブログを表示し Web UI にアクセス - E-MapReduce

このトピックでは、実行中の Flink ジョブのログを表示する方法および Flink Web UI にアクセスする方法について説明します。

前提条件

開始する前に、以下の条件を満たしていることを確認してください。

E-MapReduce (EMR) コンソールの「EMR on ACK」ページで Flink クラスターが作成済みであること。詳細については、「クイックスタート」をご参照ください。

JobManager および TaskManager のログは、EMR コンソールから直接確認できます。

EMR コンソールにログインします。左側のナビゲーションウィンドウで、EMR on ACK をクリックします。
EMR on ACK ページで、対象の Flink クラスターを特定し、ACK クラスター 列に表示される Container Service for Kubernetes (ACK) クラスターの名前をクリックします。
Pods ページで、対象の Pod を特定し、操作列のログをクリックします。コンソールに、ご利用の Flink ジョブに対応する JobManager または TaskManager のログが表示されます。

ローカルマシンから Flink REST サービスへポートを転送することで、Web UI にアクセスします。

ACK クラスターに kubectl を使用して接続します。詳細については、「クラスターの kubeconfig ファイルを取得して kubectl を使用してクラスターに接続する」をご参照ください。または、API オペレーションを呼び出して接続します。詳細については、「Kubernetes API の使用」をご参照ください。

次のコマンドを実行して、ローカルマシンのポート 18088 を Flink REST サービスのポート 8081 に転送します。

kubectl port-forward -n <yourClusterId> svc/basic-emr-example-rest 18088:8081

以下のプレースホルダーを実際の値に置き換えてください。

プレースホルダー	説明	取得方法
`<yourClusterId>`	Flink クラスターの ID	EMR コンソールの EMR on ACK ページで確認できます
`svc/basic-emr-example-rest`	`<flink_deployment_name>-rest` 形式の Flink REST サービス名	クラスター内のすべてのサービスを一覧表示するには、`kubectl get svc -n <yourClusterId>` を実行します