このトピックでは、実行中のFlinkジョブのログを表示し、ジョブのWebユーザーインターフェース(UI)にアクセスする方法について説明します。
前提条件
E-MapReduce(EMR)コンソールのEMR on ACKページでFlinkクラスタが作成されていること。詳細については、「はじめに」をご参照ください。
Flinkジョブのログの表示
EMRコンソール にログインします。左側のナビゲーションペインで、[EMR on ACK] をクリックします。
[EMR On ACK] ページで、管理するFlinkクラスタを見つけ、[ACKクラスタ] 列にあるContainer Service for Kubernetes(ACK)クラスタの名前をクリックします。
[ポッド] ページで、管理するポッドを見つけ、[アクション] 列の [ログ] をクリックします。
FlinkジョブのJobManagerまたはTaskManagerログを表示できます。
FlinkジョブのWeb UIへのアクセス
kubectlを使用して、Alibaba Cloud Container Service for Kubernetes(ACK)クラスタに接続します。詳細については、「クラスタのkubeconfigファイルを取得し、kubectlを使用してクラスタに接続する」をご参照ください。
APIオペレーションを呼び出すことによって、ACKクラスタに接続することもできます。詳細については、「Kubernetes APIを使用する」をご参照ください。
次のコマンドを実行して、オンプレミスマシンのポートを、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 形式のサービス名を指定します。
ブラウザを使用して http://127.0.0.1:18088/#/overview にアクセスし、Flinkジョブの状態を表示します。
