flink on k8s模式通过web UI界面查看任务运行情况

Posted 2022-03-10 张小凡vip

我们之前已经成功部署了flink on k8s

flink on k8s部署方案实践–详细步骤

单纯看pod的log，是无法查看和排查所有情况的。 有时候需要查看job的运行情况。

一般我们在运行flink任务时，需要查看它的job运行情况。

比较常用的方式就是在flink的UI界面上查看。

一般的flink 因为jobmanager 所在的node是固定的，ip也就是固定的，所以能够通过ip或者域名映射后即可很方便的进行访问。

flink on k8s比较特别的是jobmanager 是一个在k8s集群中临时启动的pod，它一般没有外部ip，只有k8s的内部ip，同时这个内部ip 每次jobmanager 启动后 可能是不一样的。

本篇文章记录 如下访问flink on k8s的 web UI查看任务运行情况。

启动一个flink集群提交任务

详细步骤参考之前的文章

成功启动job提交任务后 查看pod的log 输出如下：

zhangxiaofans-MacBook-Pro:Downloads joe$ kubectl logs my-flink-job-s3-job-submitter-j5cg5
---------- Checking job manager status ----------
Checking job manager to be ready. Will check success of 2 API calls for stable job submission.
curl -sS "http://my-flink-job-s3-jobmanager:8081/jobs"