You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2022/01/31 17:50:49 UTC
[flink] branch master updated (d874b26 -> fb14d4d)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from d874b26 [hotfix][tests] Fix SessionDispatcherLeaderProcessTest.onRemovedJobGraph_terminatesRunningJob
add fb14d4d [FLINK-25855] Allow JobMaster to accept excess slots when restarting the job
No new revisions were added by this update.
Summary of changes:
.../jobmaster/slotpool/DeclarativeSlotPool.java | 15 +++++
.../slotpool/DeclarativeSlotPoolBridge.java | 50 +++++++++++++++++
.../slotpool/DefaultDeclarativeSlotPool.java | 65 ++++++++++++++++++----
.../flink/runtime/jobmaster/slotpool/SlotPool.java | 7 +++
.../runtime/scheduler/DefaultSchedulerFactory.java | 10 +++-
.../flink/runtime/taskexecutor/slot/SlotOffer.java | 12 ++++
.../flink/runtime/jobmaster/JobMasterTest.java | 59 ++++++++++++++++++++
.../slotpool/DeclarativeSlotPoolBridgeTest.java | 35 ++++++++++++
.../slotpool/DefaultDeclarativeSlotPoolTest.java | 26 +++++++++
.../slotpool/TestingDeclarativeSlotPool.java | 21 +++++++
.../TestingDeclarativeSlotPoolBuilder.java | 16 ++++++
11 files changed, 305 insertions(+), 11 deletions(-)