jobmanager
scheduler：这部分与 Flink 的任务调度有关。
CoLocationConstraint：这是一个约束类，用于确保某些算子的不同子任务在同一个 TaskManager 上运行。这通常用于状态共享或算子链的情况。 CoLocationGroup & CoLocationGroupImpl：这些与 CoLocationConstraint 相关，定义了一组需要在同一个 TaskManager 上共同定位的任务。 Locality：表示任务的位置偏好，例如，希望任务在数据所在的节点上执行以最小化数据传输。 LocationPreferenceConstraint：表示任务对于特定 TaskManager 的位置偏好。 NoResourceAvailableException：当没有足够的资源满足任务的需求时抛出的异常。 SlotSharingGroup：表示可以共享同一个 TaskManager 中的插槽的任务。通过这种方式，多个算子可以运行在同一个 TaskManager 的 JVM 中，从而节省资源。slots：这部分与 TaskManag