This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 1ef0e7c34f5 [FLINK-28379][tests] Prevent mocked UGI bleeding into
other tests
new b67f0a70662 [hotfix][runtime][tests] Migrate
DeclarativeSlotPoolServiceTest and JobMasterTest to JUnit5
new f2f83e1956e [FLINK-28144][runtime] Introduce
BlocklistDeclarativeSlotPool.
new 04f2f0c2660 [FLINK-28144][runtime] Introduce
SlotPoolService#releaseFreeSlotsOnTaskManager to release free slots eagerly
when blocking nodes
new 72ea8b5999b [FLINK-28144][runtime] Introduce blocklist handler factory
and a no-op blocklist handler.
new 387b2a473d0 [FLINK-28144][runtime] Let JobMaster support blocklist.
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/runtime/blocklist/BlockedNode.java | 2 +-
.../BlockedTaskManagerChecker.java} | 18 +-
.../flink/runtime/blocklist/BlocklistHandler.java | 23 ++
.../flink/runtime/blocklist/BlocklistListener.java | 6 +-
.../flink/runtime/blocklist/BlocklistUtils.java | 45 +++
.../runtime/blocklist/DefaultBlocklistHandler.java | 35 +-
.../runtime/blocklist/NoOpBlocklistHandler.java | 64 ++++
.../DefaultSlotPoolServiceSchedulerFactory.java | 6 +-
.../apache/flink/runtime/jobmaster/JobMaster.java | 78 ++++-
.../flink/runtime/jobmaster/JobMasterGateway.java | 4 +-
.../jobmaster/SlotPoolServiceSchedulerFactory.java | 5 +-
.../factories/DefaultJobMasterServiceFactory.java | 3 +
.../jobmaster/slotpool/AllocatedSlotPool.java | 8 +
.../slotpool/BlocklistDeclarativeSlotPool.java | 124 +++++++
...va => BlocklistDeclarativeSlotPoolFactory.java} | 17 +-
.../jobmaster/slotpool/DeclarativeSlotPool.java | 10 +-
.../slotpool/DeclarativeSlotPoolBridge.java | 3 +-
.../DeclarativeSlotPoolBridgeServiceFactory.java | 5 +-
.../slotpool/DeclarativeSlotPoolService.java | 26 ++
.../DeclarativeSlotPoolServiceFactory.java | 5 +-
.../slotpool/DefaultAllocatedSlotPool.java | 5 +
.../slotpool/DefaultDeclarativeSlotPool.java | 5 +-
.../jobmaster/slotpool/SlotPoolService.java | 8 +
.../jobmaster/slotpool/SlotPoolServiceFactory.java | 3 +-
.../blocklist/DefaultBlocklistHandlerTest.java | 13 +-
.../flink/runtime/jobmaster/JobMasterTest.java | 375 ++++++++++++---------
.../slotpool/BlocklistDeclarativeSlotPoolTest.java | 246 ++++++++++++++
.../slotpool/DeclarativeSlotPoolBridgeTest.java | 7 +-
.../slotpool/DeclarativeSlotPoolServiceTest.java | 132 +++++---
.../slotpool/DefaultDeclarativeSlotPoolTest.java | 12 +-
.../jobmaster/slotpool/SlotPoolTestUtils.java | 10 +
.../slotpool/TestingDeclarativeSlotPool.java | 19 +-
.../TestingDeclarativeSlotPoolBuilder.java | 18 +-
.../jobmaster/slotpool/TestingSlotPoolService.java | 6 +
.../slotpool/TestingSlotPoolServiceBuilder.java | 3 +-
.../runtime/jobmaster/utils/JobMasterBuilder.java | 11 +
.../jobmaster/utils/TestingJobMasterGateway.java | 6 +
37 files changed, 1102 insertions(+), 264 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/{io/network/partition/TaskExecutorClusterPartitionReleaser.java
=> blocklist/BlockedTaskManagerChecker.java} (64%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/blocklist/BlocklistUtils.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/blocklist/NoOpBlocklistHandler.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/BlocklistDeclarativeSlotPool.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/{DefaultDeclarativeSlotPoolFactory.java
=> BlocklistDeclarativeSlotPoolFactory.java} (69%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/BlocklistDeclarativeSlotPoolTest.java
