Блог

У нас есть 4 диспетчера задач ™, каждый из которых работает с одним рабочим потоком. Мы пробовали использовать несколько рабочих потоков в каждом диспетчере задач, но он случайным образом отправляет разные приложения в рабочий поток одного менеджера задач. Теперь проблема в том, что если какое-либо приложение выходит из строя, оно выводит из строя всю систему, выводя из строя все другие приложения.

Итак, могу ли я отправить свое приложение в конкретную тм, чтобы все рабочие потоки в этой тм запускали только одно приложение (многопоточное). Никакого влияния на это приложение не будет оказываться на другие приложения.

Планировщик Flink не обеспечивает такого уровня управления. Для лучшей изоляции лучше всего использовать кластеры для каждого задания или приложения.

Развертывание приложения в Flink: Текущее состояние и новый режим приложения.