Я запустил приложение flink с n TaskManager и s слотами для каждого TaskManager, так что у моего приложения будет n * s слотов.
Это означает, что flink сможет запускатьсяn*s подзадач максимально одновременно.Но почему Flink не пытается использовать большинство ресурсов для выполнения как можно большего числа подзадач и не беспокоит конечных пользователей, чтобы явно установить параллелизм?
Для начинающих Flink, которые не знают настройки параллелизма (по умолчанию1), он всегда будет запускать только одну подзадачу, даже если будет выделено больше ресурсов!
Я хотел бы узнать здесь о конструктивных особенностях, спасибо!