すべてのプロダクト
Search
ドキュメントセンター

E-MapReduce:Flinkジョブのログの表示とジョブのWeb UIへのアクセス

最終更新日:Jan 11, 2025

このトピックでは、実行中のFlinkジョブのログを表示し、ジョブのWebユーザーインターフェース(UI)にアクセスする方法について説明します。

前提条件

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

Flinkジョブのログの表示

  1. EMRコンソール にログインします。左側のナビゲーションペインで、[EMR on ACK] をクリックします。

  2. [EMR On ACK] ページで、管理するFlinkクラスタを見つけ、[ACKクラスタ] 列にあるContainer Service for Kubernetes(ACK)クラスタの名前をクリックします。

  3. [ポッド] ページで、管理するポッドを見つけ、[アクション] 列の [ログ] をクリックします。

    FlinkジョブのJobManagerまたはTaskManagerログを表示できます。

FlinkジョブのWeb UIへのアクセス

  1. kubectlを使用して、Alibaba Cloud Container Service for Kubernetes(ACK)クラスタに接続します。詳細については、「クラスタのkubeconfigファイルを取得し、kubectlを使用してクラスタに接続する」をご参照ください。

    APIオペレーションを呼び出すことによって、ACKクラスタに接続することもできます。詳細については、「Kubernetes APIを使用する」をご参照ください。

  2. 次のコマンドを実行して、オンプレミスマシンのポートを、Flinkジョブが実行されているサービスのポートに転送します。これにより、オンプレミスマシンからサービスにアクセスできます。

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

    コマンドのサンプルコードは参照用です。次の変数を実際の値に置き換える必要があります。

    • <yourClusterId>: FlinkクラスタのID。クラスタ ID は、EMRコンソールのEMR on ACKページで取得できます。

    • svc/basic-emr-example-rest: Flinkジョブが実行されているサービスの名前。kubectl get svc -n <yourClusterId> コマンドを実行して、Flinkクラスタ内のすべてのKubernetesサービスをクエリできます。ポート転送のために、<flink_deployment_name>-rest 形式のサービス名を指定します。

  3. ブラウザを使用して http://127.0.0.1:18088/#/overview にアクセスし、Flinkジョブの状態を表示します。

    job run