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 d9c5b43 [FLINK-19984][core] Add TypeSerializerTestCoverageTest
add e967b98 [FLINK-19636][coordination] Refactor matching logic to make
it re-usable
add c2db57e [FLINK-19636][coordination] Add DeclarativeSlotPool
add c1b96de [FLINK-19715][coordination] Fix inefficiencies in assignment
of excess resources
No new revisions were added by this update.
Summary of changes:
.../jobmaster/slotpool/DeclarativeSlotPool.java | 151 ++++++
.../slotpool/DefaultDeclarativeSlotPool.java | 440 +++++++++++++++++
.../jobmaster/slotpool/ResourceCounter.java | 254 ++++++++++
.../slotmanager/JobScopedResourceTracker.java | 42 +-
.../runtime/slots/DefaultRequirementMatcher.java | 45 ++
.../RequirementMatcher.java} | 29 +-
.../DefaultDeclarativeSlotPoolBuilder.java | 69 +++
.../slotpool/DefaultDeclarativeSlotPoolTest.java | 550 +++++++++++++++++++++
.../jobmaster/slotpool/ResourceCounterTest.java | 174 +++++++
9 files changed, 1721 insertions(+), 33 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPool.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPool.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/ResourceCounter.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/slots/DefaultRequirementMatcher.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/{io/network/partition/ClusterPartitionManager.java
=> slots/RequirementMatcher.java} (50%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPoolBuilder.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPoolTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/ResourceCounterTest.java
