В сеансе Kubernetes или развертывании для каждого задания Flink не знает, что он работает на Kubernetes. В этом режиме Flink ведет себя так же, как и при любом автономном развертывании (где нет кластерной инфраструктуры для управления ресурсами). Kubernetes - это просто то, как была создана инфраструктура, но, что касается Flink, это могло быть голое железо. Вам нужно будет организовать кубернеты для создания инфраструктуры, которую вы настроили для Flink для ожидания. кластера, который он хочет, на Kubernetes ApiServer, который его создает. По мере поступления заданий и go и требований к диспетчерам задач (и слотов) go вверх и вниз, Flink может получать и высвобождать ресурсы из кубернетов по мере необходимости.
В Application Mode ( сообщение в блоге ) ( подробности ) в конечном итоге Flink работает как приложение kubernetes, которое автоматически создает и уничтожает компоненты кластера по мере необходимости для заданий в одно приложение Flink.