E-MapReduce：查看Flink作業日誌和訪問Flink Web UI

前提條件

已在E-MapReduce on ACK控制台建立Flink叢集，詳情請參見快速入門。

查看Flink作業日誌

1. 登入EMR on ACK。

2. 在EMR on ACK頁面，單擊目的地組群所在行所属 ACK 集群列的連結。

3. 在容器組頁面，單擊目標Pod操作列的日志。

   則可查看對應JobManager或者TaskManager的日誌。

訪問Flink Web UI

1. 通過kubectl串連Kubernetes叢集，詳情請參見擷取叢集KubeConfig並通過kubectl工具串連叢集。

   您也可以通過API等方式串連Kubernetes叢集，詳情請參見使用Kubernetes API。

2. 執行以下命令，轉寄Flink作業JobManager的服務到本地進行訪問。

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

   說明

   範例程式碼中需替換以下參數：

   • <yourClusterId>：叢集ID，您可以登入E-MapReduce on ACK控制台，在叢集管理頁面擷取。

   • svc/basic-emr-example-rest：您啟動並執行Flink作業的服務名稱，您可以通過命令kubectl get svc -n <yourClusterId>查看所有的K8s服務。請選擇<flink_deployment_name>-rest服務進行轉寄。

3. 在瀏覽器中訪問http://127.0.0.1:18088/#/overview，查看作業運行情況。

   頁面顯示 Available Task Slots 為 0，Total Task Slots 為 2，Task Managers 為 1。Running Jobs 為 1，Running Job List 中包含名為 State machine job 的作業，狀態為 RUNNING，共 4 個任務均在運行中。