zentol opened a new pull request #14921: URL: https://github.com/apache/flink/pull/14921
Based on #14909 and #14910. Implements the `DeclarativeScheduler`. It primarily connects the various `State` classes, the `SlotAllocator` and `ScaleUpController` to create a new streaming-only scheduler that can automatically scale down jobs if not enough slots are available, and scale up automatically once these slots are available. Contains various other smaller change; one of note is a change in the lifecycle of the declarative `SharedSlot` implementation where the external release callback is now only called during normal execution, i.e., if all logical slots were properly returned. The goal was to make the code easier to reason about, and prevent multiple `release` calls. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
