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 efd4974 [hotfix][e2e] Sync kafka 0.10 versions
add 4b7d8db [hotfix][runtime] Move shared static test methods of physical
slot into PhysicalSlotTestUtils
add a1c9a30 [hotfix][runtime] Move shared static test methods of slot
allocator into ExecutionSlotAllocatorTestUtils
add 6d9eb50 [FLINK-17018][runtime] Extract common logics of
DefaultExecutionSlotAllocator into AbstractExecutionSlotAllocator
add 95cf59a [FLINK-17018][runtime] Introduce
OneSlotPerExecutionSlotAllocator which will request one physical slot for each
single execution vertex
add d75f186 [FLINK-17018][runtime] Use OneSlotPerExecutionSlotAllocator
on pipelined region scheduling
add a10f1a47 [hotfix][runtime] Narrow down the access scope of
DefaultExecutionSlotAllocator
add 0aea300 [hotfix][runtime] Narrow down the access scope of
SlotExecutionVertexAssignment
No new revisions were added by this update.
Summary of changes:
.../jobmaster/slotpool/PhysicalSlotRequest.java | 6 +-
.../jobmaster/slotpool/SingleLogicalSlot.java | 2 +-
.../scheduler/AbstractExecutionSlotAllocator.java | 131 +++++++++
.../scheduler/DefaultExecutionSlotAllocator.java | 134 +++------
.../DefaultExecutionSlotAllocatorFactory.java | 4 +-
.../runtime/scheduler/DefaultSchedulerFactory.java | 34 ++-
.../OneSlotPerExecutionSlotAllocator.java | 217 +++++++++++++++
...> OneSlotPerExecutionSlotAllocatorFactory.java} | 26 +-
.../scheduler/SlotExecutionVertexAssignment.java | 8 +-
.../slotpool/AllocatedSlotOccupationTest.java | 35 +--
.../PhysicalSlotRequestBulkCheckerTest.java | 28 +-
...upationTest.java => PhysicalSlotTestUtils.java} | 33 +--
.../AbstractExecutionSlotAllocatorTest.java | 178 ++++++++++++
.../DefaultExecutionSlotAllocatorTest.java | 151 ++--------
.../scheduler/ExecutionSlotAllocatorTestUtils.java | 61 +++++
.../OneSlotPerExecutionSlotAllocatorTest.java | 304 +++++++++++++++++++++
16 files changed, 1035 insertions(+), 317 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/AbstractExecutionSlotAllocator.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/OneSlotPerExecutionSlotAllocator.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/{DefaultExecutionSlotAllocatorFactory.java
=> OneSlotPerExecutionSlotAllocatorFactory.java} (56%)
copy
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/{AllocatedSlotOccupationTest.java
=> PhysicalSlotTestUtils.java} (66%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/AbstractExecutionSlotAllocatorTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/ExecutionSlotAllocatorTestUtils.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/OneSlotPerExecutionSlotAllocatorTest.java
