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

Posted to commits@flink.apache.org by ch...@apache.org on 2023/07/05 15:58:22 UTC

[flink] branch master updated (e56e87ee225 -> 38f4d133a78)

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 e56e87ee225 [hotfix][test] Migrates EmbeddedLeaderServiceTest to JUnit5/AssertJ
     add 38f4d133a78 [FLINK-31476] AdaptiveScheduler respects minimum parallelism

No new revisions were added by this update.

Summary of changes:
 .../scheduler/DefaultVertexParallelismInfo.java    |  15 ++
 .../scheduler/DefaultVertexParallelismStore.java   |  12 +-
 .../scheduler/VertexParallelismInformation.java    |   8 +
 .../scheduler/adaptive/JobGraphJobInformation.java |   5 +
 .../adaptive/allocator/JobInformation.java         |   2 +
 .../allocator/SlotSharingSlotAllocator.java        | 150 ++++++++++++---
 .../DefaultVertexParallelismStoreTest.java         |   5 +
 .../scheduler/adaptive/AdaptiveSchedulerTest.java  | 214 ++++++++++++++++++++-
 .../allocator/SlotSharingSlotAllocatorTest.java    | 109 +++++++++++
 .../adaptive/allocator/TestVertexInformation.java  |  15 ++
 10 files changed, 493 insertions(+), 42 deletions(-)