细粒度资源管理的背景
目的
Flink 目前采用粗粒度的资源管理方法，其中task被部署到预定义的、通常相同的slot中，而不需要每个包含多少资源的概念。使用slot共享，可以将同一slot共享组 (SSG)中的task部署到一个slot中，而不管每个task/operator需要多少资源。在FLIP-56中，我们提出了细粒度资源管理，它根据工作负载的资源需求，利用具有不同资源的slot来执行task。
对于许多job来说，使用粗粒度的资源管理并将所有task简单地放在一个 SSG 中就足够了，无论是在资源利用率还是可用性方面。
- 对于所有task都具有相同并行度的许多流式job，每个slot将包含一个完整的pipeline。理想情况下，所有pipeline应该使用大致相同的资源，这可以通过调整相同slot的资源轻松满足。
- task的资源消耗随时间而变化。当一个task的消耗减少时，额外的资源可以被另一个消耗增加的task使用。这被称为削峰填谷效应，减少了所需的整体资源。
但是，在某些情况下，粗粒度的资源管理不能很好地工作。
- task可能有不同的并行度。有时，无法避免这种不同的并行性。例如，source/sink/lookup task的并行性可能会受到外部上游/下游系统的分区和 IO 负载的限制。在这种情况下，具有较少task的slot将比具有整个task pipeline的slot需要更少的资源。
- 有时，整个pipeline所需的资源可能太多，无法放入单个slot/task管理器中。在这种情况下，pipeline需要拆分为多个 SSG，它们可能并不总是具有相同的资源需求。
- 对于批处理job，并非所有task都可以同时执行。因此，pipeline的瞬时资源需求随时间而变化。
尝试使用相同的slot执行所有task可能会导致非最佳资源利用率。相同slot位的资源必须能够满足最高资源要求，这对于其他要求将是浪费的。当涉及到 GPU 等昂贵的外部资源时，这种浪费会变得更加难以承受。
因此，需要细粒度的资源管理，利用不同资源的slot来提高这种场景下的资源利用率。