Flink on k8s

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

Flink on k8s

superainbower
hi,我在尝试flink on k8s部署,搭建了minikube,按照官方文档部署之后
1.在flink ui界面 看不到taskmanger的信息,任务提交的时候会提示没有slot,像是taskmanger没有注册到jobmanger
2.k8s dashboard上,taskmanger过不了一会就重启
请问下大家有遇过吗?不知道该怎么排查解决
Reply | Threaded
Open this post in threaded view
|

Re: Flink on k8s

Yang Wang
需要你发一下TaskManager的log,这样才能方便排查问题
你可以使用kubectl logs来直接查看log

另外你是用的官方文档[1]里面的yaml来启动的吗,E2E测试(minikube版本是v1.8.2)都是正常运行的,我在真实的K8s集群测试也没问题


[1].
https://ci.apache.org/projects/flink/flink-docs-master/ops/deployment/kubernetes.html#deploy-flink-cluster-on-kubernetes


Best,
Yang

superainbower <[hidden email]> 于2020年9月1日周二 下午7:00写道:

> hi,我在尝试flink on k8s部署,搭建了minikube,按照官方文档部署之后
> 1.在flink ui界面 看不到taskmanger的信息,任务提交的时候会提示没有slot,像是taskmanger没有注册到jobmanger
> 2.k8s dashboard上,taskmanger过不了一会就重启
> 请问下大家有遇过吗?不知道该怎么排查解决
Reply | Threaded
Open this post in threaded view
|

Re: Flink on k8s

tonychen
In reply to this post by superainbower
同样的问题遇到过一次,最后查出还是job的问题。job写的不正当,运行一段会不停的restart,最后导致TM重启。
可以从job的角度查一下


Best,
TonyChen

> 2020年9月1日 下午6:50,superainbower <[hidden email]> 写道:
>
> hi,我在尝试flink on k8s部署,搭建了minikube,按照官方文档部署之后
> 1.在flink ui界面 看不到taskmanger的信息,任务提交的时候会提示没有slot,像是taskmanger没有注册到jobmanger
> 2.k8s dashboard上,taskmanger过不了一会就重启
> 请问下大家有遇过吗?不知道该怎么排查解决