This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 8d430f51d77 [FLINK-31995][tests] Adds shutdown check to
DirectExecutorService
add 2cabb157a4f [hotfix] Keep all calculations and deriving in
SlotManagerConfiguration#fromConfiguration
add 92f8666ec1d [FLINK-31443][runtime] Only check idle timeout when
resource allocator is supported.
add 62d3a47a990 [FLINK-31443][runtime] let ResourceAllocationStrategy
decide which pending/idle task managers should be release.
add 8a2b2729b9f [FLINK-31443][runtime] Maintain
pendingSlotAllocationRecords in PendingTaskManager
add 00b1d4cf880 [FLINK-31443][runtime] Maintain redundant task managers to
speed up failover
No new revisions were added by this update.
Summary of changes:
.../generated/resource_manager_configuration.html | 2 +-
.../configuration/ResourceManagerOptions.java | 9 +-
.../ResourceManagerRuntimeServices.java | 4 +-
.../DefaultResourceAllocationStrategy.java | 137 ++++++++++++++-
.../slotmanager/FineGrainedSlotManager.java | 98 ++++++-----
.../slotmanager/FineGrainedTaskManagerTracker.java | 41 ++---
.../slotmanager/PendingTaskManager.java | 41 +++++
.../slotmanager/ResourceAllocationStrategy.java | 13 ++
.../slotmanager/ResourceReleaseResult.java | 70 ++++++++
.../slotmanager/SlotManagerConfiguration.java | 11 +-
.../slotmanager/TaskExecutorManager.java | 41 +++--
.../TaskManagerResourceInfoProvider.java | 11 --
.../apache/flink/runtime/util/ResourceCounter.java | 11 ++
.../slotmanager/DeclarativeSlotManagerBuilder.java | 3 +
.../DefaultResourceAllocationStrategyTest.java | 193 ++++++++++++++++++++-
...gerDefaultResourceAllocationStrategyITCase.java | 101 ++++++++++-
.../slotmanager/FineGrainedSlotManagerTest.java | 112 ++----------
.../FineGrainedTaskManagerTrackerTest.java | 46 +++--
.../SlotManagerConfigurationBuilder.java | 3 +
.../TestingResourceAllocationStrategy.java | 30 +++-
.../slotmanager/TestingTaskManagerInfo.java | 10 +-
.../TestingTaskManagerResourceInfoProvider.java | 27 ---
22 files changed, 746 insertions(+), 268 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/ResourceReleaseResult.java
