This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6cf98b6 [FLINK-12804] Change mailbox implementation from bounded to
unbounded
new 0421594 [FLINK-12766][runtime] Introduce merge and subtract
calculations and tests for ResourceProfile.
new f6857a4 [FLINK-12765][coordinator] Change the default resource spec
to UNKNOWN
new c5072df [hotfix] [tests] Checkstyle fixes and minor code cleanup in
ResourceProfileTest and ResourceSpecTest
new 2947015 [FLINK-12766][runtime] Fix bug in merging and converting
UNKNOWN ResourceSpecs.
new e6ef677 [hotfix][runtime] Preserve singleton property of UNKNOWN
ResourceSpec and ResourceProfile
new 5654e0f [hotfix][core] Minor cleanups to the ResourceSpec class
new faa839d [FLINK-12765][coordinator] Disable jobs where some, but nor
all, vertices have configured resource profiles
new bcec7d7 [FLINK-12765][jobmanager] Keep track of the resources used in
the task slot hierarchy
new a587576 [FLINK-12765][jobmanager] Let some slot reqests fail if the
sharing slot is oversubscribed
new d56c45a [FLINK-13250][blink runner] Make sure that all nodes have a
concrete resource profile
The 10 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/api/common/operators/ResourceSpec.java | 57 +++-
.../flink/api/common/resources/Resource.java | 35 ++-
.../api/common/operators/ResourceSpecTest.java | 73 +++++-
.../clusterframework/types/ResourceProfile.java | 142 +++++++++-
.../flink/runtime/dispatcher/Dispatcher.java | 25 ++
.../runtime/jobmaster/slotpool/SchedulerImpl.java | 54 +++-
...java => SharedSlotOversubscribedException.java} | 32 +--
.../jobmaster/slotpool/SlotSharingManager.java | 138 +++++++++-
.../types/ResourceProfileTest.java | 125 ++++++++-
.../flink/runtime/dispatcher/DispatcherTest.java | 40 +++
.../jobmaster/slotpool/SlotPoolCoLocationTest.java | 162 ++++++++++++
.../slotpool/SlotPoolSlotSharingTest.java | 92 +++++++
.../jobmaster/slotpool/SlotSharingManagerTest.java | 291 +++++++++++++++++++++
.../apache/flink/table/executor/BatchExecutor.java | 4 +-
14 files changed, 1206 insertions(+), 64 deletions(-)
mode change 100644 => 100755
flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java
mode change 100644 => 100755
flink-core/src/test/java/org/apache/flink/api/common/operators/ResourceSpecTest.java
mode change 100644 => 100755
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/{AllocatedSlotActions.java
=> SharedSlotOversubscribedException.java} (60%)
mode change 100644 => 100755
flink-runtime/src/test/java/org/apache/flink/runtime/clusterframework/types/ResourceProfileTest.java
mode change 100644 => 100755
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
