You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by az...@apache.org on 2020/08/17 08:20:53 UTC

[flink] branch master updated (f5b644a -> ff94e8b)

This is an automated email from the ASF dual-hosted git repository.

azagrebin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from f5b644a  [FLINK-18963][docs] Introduced IntelliJ subsection about adding a Copyright Profile for the Apache license.
     add f92789e  [hotfix] Move DualKeyLinkedMap to util package
     add ff94e8b  [FLINK-18751][Coordination] Implement SlotSharingExecutionSlotAllocator

No new revisions were added by this update.

Summary of changes:
 .../jobmaster/slotpool/PhysicalSlotProvider.java   |   2 +-
 .../jobmaster/slotpool/PhysicalSlotRequest.java    |   2 +-
 .../runtime/jobmaster/slotpool/SlotPoolImpl.java   |   1 +
 .../SlotSharingExecutionSlotAllocator.java         | 301 +++++++++++
 .../SlotSharingExecutionSlotAllocatorFactory.java  |  66 +++
 .../slotpool => util}/DualKeyLinkedMap.java        |  69 +--
 .../jobmaster/slotpool/PhysicalSlotTestUtils.java  |   6 +-
 .../SlotSharingExecutionSlotAllocatorTest.java     | 550 +++++++++++++++++++++
 .../slotpool => util}/DualKeyLinkedMapTest.java    |   2 +-
 9 files changed, 949 insertions(+), 50 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingExecutionSlotAllocator.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingExecutionSlotAllocatorFactory.java
 rename flink-runtime/src/main/java/org/apache/flink/runtime/{jobmaster/slotpool => util}/DualKeyLinkedMap.java (81%)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/SlotSharingExecutionSlotAllocatorTest.java
 rename flink-runtime/src/test/java/org/apache/flink/runtime/{jobmaster/slotpool => util}/DualKeyLinkedMapTest.java (98%)