你这个需求是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 <[email protected]> 于2021年11月15日周一 下午6:25写道:

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

回复