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/06 09:46:27 UTC

[flink] branch master updated (b019c72 -> df15f7e)

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 b019c72  [hotfix][runtime] Fix typo in SlotPoolImpl
     add 1e1fa56  [hotfix] Fix potential test concurrency instability in BulkSlotProviderImplTest
     add df15f7e  [FLINK-18709][Coordination] Implement PhysicalSlotProvider

No new revisions were added by this update.

Summary of changes:
 ...SlotProvider.java => PhysicalSlotProvider.java} |  32 ++----
 .../slotpool/PhysicalSlotProviderImpl.java         |  99 ++++++++++++++++++
 .../slotpool/BulkSlotProviderImplTest.java         |   8 +-
 .../slotpool/PhysicalSlotProviderImplTest.java     | 113 +++++++++++++++++++++
 4 files changed, 227 insertions(+), 25 deletions(-)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/{BulkSlotProvider.java => PhysicalSlotProvider.java} (54%)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotProviderImpl.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotProviderImplTest.java