You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2020/10/16 09:46:51 UTC
[flink] branch master updated (ea599af -> 50671d3)

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 ea599af  [FLINK-19671] Update .editorconfig to conform to checkstyle and import ordering
     add 3d7f96a  [hotfix][coordination] Remove unused SlotManager#unregisterTaskManagersAndReleaseResources
     add e44c932  [FLINK-19306][coordination] Add DeclarativeSlotManager
     add 50671d3  [FLINK-19306][coordination] ResourceManager supports declarative resource management

No new revisions were added by this update.

Summary of changes:
 .../runtime/resourcemanager/ResourceManager.java   |  30 +
 .../resourcemanager/ResourceManagerGateway.java    |  13 +
 .../ResourceManagerRuntimeServices.java            |  10 +-
 .../slotmanager/DeclarativeSlotManager.java        | 638 +++++++++++++
 .../slotmanager/DefaultSlotTracker.java            |   8 +-
 .../slotmanager/ResourceActions.java               |  11 +
 .../resourcemanager/slotmanager/SlotManager.java   |  20 +-
 .../slotmanager/SlotManagerImpl.java               |  24 +-
 .../flink/runtime/slots/ResourceCounter.java       |   2 +-
 ...der.java => DeclarativeSlotManagerBuilder.java} |  70 +-
 .../slotmanager/DeclarativeSlotManagerTest.java    | 999 +++++++++++++++++++++
 .../slotmanager/TestingResourceActions.java        |  14 +-
 .../slotmanager/TestingResourceActionsBuilder.java |  10 +-
 .../slotmanager/TestingSlotManager.java            |  10 +-
 .../utils/TestingResourceManagerGateway.java       |  13 +
 15 files changed, 1817 insertions(+), 55 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManager.java
 copy flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/{SlotManagerBuilder.java => DeclarativeSlotManagerBuilder.java} (59%)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManagerTest.java