This is an automated email from the ASF dual-hosted git repository.
weizhong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from e7639297bec [FLINK-38572][model] Support controlling randomness and
format of Chat Model Function (#27155)
new 252f6521aa8 [FLINK-33389][refactor] Make
TaskBalancedExecutionSlotSharingGroupBuilder as a separated class.
new 08050f8c263 [FLINK-33389][refactor] Extract the assignment logic of
task to slot as SlotSharingResolver then refactor the implementation of the
default resover.
new ae962a87705 [FLINK-33389][runtime] Add the co-location related methods
for related abstractions of adaptive scheduler.
new ca20e1d8a18 [FLINK-33389][runtime] Support tasks balancing at slot
level for Adaptive Scheduler
The 4 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:
.../scheduler/AbstractSlotSharingStrategy.java | 19 +-
.../scheduler/ExecutionSlotSharingGroup.java | 4 +-
.../LocalInputPreferredSlotSharingStrategy.java | 3 +-
...skBalancedExecutionSlotSharingGroupBuilder.java | 263 +++++++++++++++++++++
.../TaskBalancedPreferredSlotSharingStrategy.java | 247 +------------------
.../scheduler/adaptive/JobGraphJobInformation.java | 14 ++
.../adaptive/allocator/AllocatorUtil.java | 27 ---
.../adaptive/allocator/DefaultSlotAssigner.java | 16 +-
...orUtil.java => DefaultSlotSharingResolver.java} | 51 ++--
.../adaptive/allocator/JobInformation.java | 16 ++
...{SlotAssigner.java => SlotSharingResolver.java} | 28 ++-
.../allocator/SlotSharingSlotAllocator.java | 31 ++-
.../allocator/StateLocalitySlotAssigner.java | 21 +-
.../allocator/TaskBalancedSlotSharingResolver.java | 76 ++++++
.../TaskBalancedSlotSharingResolverTest.java | 254 ++++++++++++++++++++
.../allocator/DefaultSlotAssignerTest.java | 5 +-
.../allocator/SlotSharingSlotAllocatorTest.java | 4 +-
.../allocator/StateLocalitySlotAssignerTest.java | 2 +-
.../adaptive/allocator/TestJobInformation.java | 22 +-
.../adaptive/allocator/TestVertexInformation.java | 64 ++++-
20 files changed, 812 insertions(+), 355 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/TaskBalancedExecutionSlotSharingGroupBuilder.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/{AllocatorUtil.java
=> DefaultSlotSharingResolver.java} (60%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/{SlotAssigner.java
=> SlotSharingResolver.java} (52%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/TaskBalancedSlotSharingResolver.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/TaskBalancedSlotSharingResolverTest.java
