You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by xt...@apache.org on 2021/02/07 12:26:58 UTC

[flink] branch master updated (0ad9a76 -> 6133f10)

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 0ad9a76  [FLINK-21047][coordination] Fix the incorrect registered/free resources information exposed by SlotManager
     add 7fc3c73  [hotfix][runtime] Remove unused check for the ResourceSpec of SlotSharingGroup in calculation manage memory fraction
     add 6911b4f  [hotfix][runtime] Remove unused ResourceSpec field in SlotSharingGroup
     add 7453c22  [FLINK-21270][runtime] Add ResourceProfile field to ExecutionSlotSharingGroup
     add 6133f10  [FLINK-21270][coordination] Generate the slot request respect to the resource specification of SlotSharingGroup if present

No new revisions were added by this update.

Summary of changes:
 .../apache/flink/runtime/jobgraph/JobVertex.java   |  4 +-
 .../jobmanager/scheduler/SlotSharingGroup.java     | 18 +-------
 .../scheduler/ExecutionSlotSharingGroup.java       | 12 ++++++
 .../LocalInputPreferredSlotSharingStrategy.java    | 18 ++++----
 .../SlotSharingExecutionSlotAllocator.java         | 14 ++++---
 .../executiongraph/VertexSlotSharingTest.java      | 38 -----------------
 ...LocalInputPreferredSlotSharingStrategyTest.java | 45 +++++++++++++++++---
 .../SlotSharingExecutionSlotAllocatorTest.java     | 43 +++++++++++++++----
 .../api/graph/StreamingJobGraphGenerator.java      | 48 ++++++++--------------
 9 files changed, 126 insertions(+), 114 deletions(-)