Вкл. пряжа и kubernetes Flink имеет собственный менеджер ресурсов (YarnResourceManager и KubernetesResourceManager), который организует наличие запрошенного количества слотов. В других средах вам нужно будет использовать механизмы c для кластерной инфраструктуры, чтобы позаботиться об этом самостоятельно.
Обратите внимание, что для k8s только новые кластеры сеансов поддерживаются этим новым, более активным режим реализован KubernetesResourceManager. Управление кластерами заданий по-прежнему необходимо выполнять по старинке, как описано в документах .
. Кроме того, существуют управляемые среды Flink, в которых об этих деталях позаботятся за вас, например: , Ververica Platform или Kinesis Data Analytics.