This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 345f36d [FLINK-21855][docs] Document metrics limitations of reactive
mode
add 616c3f4 [hotfix] Fix typo
add 11fe3c5 [FLINK-21751][coordination] Reserve disconnectJobManager for
external calls
add e12e6ef [FLINK-21751][coordination] JM passes job status when
disconnecting
add fcc9ada [FLINK-21751][coordination] Add
SlotTracker#getTaskExecutorsWithAllocatedSlotsForJob
add 1e82ff9 [FLINK-21751][coordination] Add TaskExecutor#freeInactiveSlots
add 8d0d22d [FLINK-21751][coordination] Only clear requirements for
terminal jobs
add d117ee2 [FLINK-21751][coordination] Reclaim inactive slot if
requirements are cleared
No new revisions were added by this update.
Summary of changes:
.../apache/flink/runtime/jobmaster/JobMaster.java | 3 +-
.../runtime/resourcemanager/ResourceManager.java | 41 +++++++++++---
.../resourcemanager/ResourceManagerGateway.java | 4 +-
.../slotmanager/DeclarativeSlotManager.java | 14 +++++
.../slotmanager/DefaultSlotTracker.java | 16 +++++-
.../resourcemanager/slotmanager/SlotTracker.java | 9 +++
.../flink/runtime/taskexecutor/TaskExecutor.java | 15 +++++
.../runtime/taskexecutor/TaskExecutorGateway.java | 8 +++
.../slotmanager/DeclarativeSlotManagerTest.java | 43 ++++++++++++++
.../slotmanager/DefaultSlotTrackerTest.java | 26 +++++++++
.../utils/TestingResourceManagerGateway.java | 12 ++--
.../runtime/taskexecutor/TaskExecutorTest.java | 65 ++++++++++++++++++++++
.../taskexecutor/TestingTaskExecutorGateway.java | 9 +++
.../TestingTaskExecutorGatewayBuilder.java | 9 +++
14 files changed, 258 insertions(+), 16 deletions(-)
