You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "casel.chen" <ca...@126.com> on 2021/11/15 10:25:00 UTC

flink on native k8s调度控制

flink作业跑在一个k8s集群，该集群下面有若干个节点，想将某些节点给部门A使用，其他节点给部门B使用。请问flink有配置控制k8s调度吗？
1. 给节点打上标签
2. 作业提交的时候设置调度标签值

Re: flink on native k8s调度控制

Posted by Yang Wang <da...@gmail.com>.

你这个需求是taint和toleration[1]可以解决的，目前native K8s是支持的[2]

kubernetes.jobmanager.tolerations
kubernetes.taskmanager.tolerations

[1].
https://kubernetes.io/docs/concepts/scheduling-eviction/taint-and-toleration/
[2].
https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/config/#kubernetes-jobmanager-tolerations

Best,
Yang

casel.chen <ca...@126.com> 于2021年11月15日周一 下午6:25写道：

> flink作业跑在一个k8s集群，该集群下面有若干个节点，想将某些节点给部门A使用，其他节点给部门B使用。请问flink有配置控制k8s调度吗？
> 1. 给节点打上标签
> 2. 作业提交的时候设置调度标签值