This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 556942a [FLINK-21750][table-planner-blink] Support
StreamExecWatermarkAssigner json serialization/deserialization
add 0b52cf3 [hotfix][runtime] Fix max number of slots check for TM
registration.
add 80ff16c [hotfix][runtime] Extract class ClusterResourceOverview into
interface ClusterResourceStatisticsProvider
add 4e660cf [hotfix][runtime] Maintains totalRegisteredResource in
FineGrainedTaskManagerTracker.
add ee5fcf7 [FLINK-21177][runtime] Add pending resources to
ClusterResourceStatisticsProvider.
add 3ff3aa8 [FLINK-21177][core] Make Resource comparable.
add 180b1a4 [FLINK-21177][core] Introduce
CPUResource#toHumanReadableString
add 2c30866 [FLINK-21177][runtime] Introduce
WorkerResourceSpec#getTotalMemoSize
add c775463 [FLINK-21177][runtime] Support limiting max total resources
for fine-grained resource management.
No new revisions were added by this update.
Summary of changes:
.../flink/api/common/resources/CPUResource.java | 7 +
.../flink/api/common/resources/Resource.java | 8 +-
.../configuration/ResourceManagerOptions.java | 26 ++++
.../api/common/resources/CPUResourceTest.java | 44 ++++++
.../flink/api/common/resources/ResourceTest.java | 37 ++++++
.../flink/api/common/resources/TestResource.java | 4 +
.../resourcemanager/WorkerResourceSpec.java | 4 +
.../slotmanager/ClusterResourceOverview.java | 83 ------------
.../ClusterResourceStatisticsProvider.java | 53 ++++++++
.../slotmanager/FineGrainedSlotManager.java | 85 +++++++++---
.../slotmanager/FineGrainedTaskManagerTracker.java | 80 ++++++++++-
.../slotmanager/SlotManagerConfiguration.java | 54 ++++++++
.../slotmanager/SlotManagerImpl.java | 5 +
.../slotmanager/TaskExecutorManager.java | 5 +
.../TaskManagerResourceInfoProvider.java | 7 -
.../slotmanager/TaskManagerTracker.java | 3 +-
.../resourcemanager/ResourceManagerHATest.java | 4 +
.../slotmanager/DeclarativeSlotManagerBuilder.java | 4 +
.../slotmanager/FineGrainedSlotManagerTest.java | 148 +++++++++++++++++++++
.../FineGrainedTaskManagerTrackerTest.java | 16 +--
.../slotmanager/SlotManagerBuilder.java | 4 +
.../SlotManagerConfigurationBuilder.java | 18 +++
.../TestingTaskManagerResourceInfoProvider.java | 18 ---
23 files changed, 572 insertions(+), 145 deletions(-)
create mode 100644
flink-core/src/test/java/org/apache/flink/api/common/resources/CPUResourceTest.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/ClusterResourceOverview.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/ClusterResourceStatisticsProvider.java
