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 d07140c [FLINK-20433][tests] Stabilizing UnalignedCheckpointITCase.
add 4b87866 [hotfix][coordination] Add ExcessResource#toString()
add 8393700 [hotfix][coordination][tests] Remove error message assertions
add 70695c1 [FLINK-19314][coordination][tests] Add
TestingDeclarativeSlotPoolBuilder
add ee060fc [FLINK-19314][coordination] Add DeclarativeSlotPoolFactory
add b1d300c [FLINK-19314][coordination] Extend SlotPool interface
add 11ea4b5 [FLINK-19314][coordination] Add DeclarativeSlotPoolBridge
add 2dbd32d [FLINK-19314][coordination] Wire notifications about
resources not being available
add 908d281 [FLINK-19305][coordination][CI] Setup CI run with declarative
slot management
No new revisions were added by this update.
Summary of changes:
.../apache/flink/configuration/ClusterOptions.java | 4 +-
.../apache/flink/runtime/jobmaster/JobMaster.java | 14 +-
.../flink/runtime/jobmaster/JobMasterGateway.java | 8 +
.../slotpool/DeclarativeSlotPoolBridge.java | 658 +++++++++++++++++++++
....java => DeclarativeSlotPoolBridgeFactory.java} | 20 +-
...anager.java => DeclarativeSlotPoolFactory.java} | 28 +-
...java => DefaultDeclarativeSlotPoolFactory.java} | 44 +-
.../slotpool/PhysicalSlotProviderImpl.java | 3 +-
.../runtime/jobmaster/slotpool/SchedulerImpl.java | 3 +-
.../flink/runtime/jobmaster/slotpool/SlotPool.java | 22 +-
.../jobmaster/slotpool/SlotPoolFactory.java | 8 +-
.../runtime/jobmaster/slotpool/SlotPoolImpl.java | 3 +-
.../runtime/resourcemanager/ResourceManager.java | 5 +
.../slotmanager/JobScopedResourceTracker.java | 9 +
.../flink/runtime/jobmaster/JobMasterTest.java | 2 +-
...ativeSlotPoolBridgeResourceDeclarationTest.java | 183 ++++++
.../slotpool/DeclarativeSlotPoolBridgeTest.java | 205 +++++++
.../slotpool/DefaultDeclarativeSlotPoolTest.java | 2 +-
.../jobmaster/slotpool/SlotPoolImplTest.java | 9 +-
.../slotpool/TestingDeclarativeSlotPool.java | 173 ++++++
.../TestingDeclarativeSlotPoolBuilder.java | 133 +++++
.../jobmaster/utils/TestingJobMasterGateway.java | 12 +-
.../utils/TestingJobMasterGatewayBuilder.java | 10 +-
.../runtime/minicluster/MiniClusterITCase.java | 12 -
tools/azure-pipelines/jobs-template.yml | 2 +
tools/ci/stage.sh | 10 +
tools/ci/test_controller.sh | 3 +
27 files changed, 1498 insertions(+), 87 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolBridge.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/{DefaultSlotPoolFactory.java
=> DeclarativeSlotPoolBridgeFactory.java} (72%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/{NoOpDeclareResourceRequirementServiceConnectionManager.java
=> DeclarativeSlotPoolFactory.java} (60%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/{AbstractSlotPoolFactory.java
=> DefaultDeclarativeSlotPoolFactory.java} (57%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolBridgeResourceDeclarationTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolBridgeTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/TestingDeclarativeSlotPool.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/TestingDeclarativeSlotPoolBuilder.java
