This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 1d5b214eb68 [FLINK-36246] Move async state related operators
flink-runtime (#25306)
add db682b9869d [FLINK-36014] [runtime] Align the desired and sufficient
resources definiton in Executing and WaitForResources states
No new revisions were added by this update.
Summary of changes:
.../generated/all_jobmanager_section.html | 18 ++---
.../generated/expert_scheduling_section.html | 18 ++---
.../generated/job_manager_configuration.html | 18 ++---
.../flink/configuration/JobManagerOptions.java | 61 +++++++++++++---
.../scheduler/adaptive/AdaptiveScheduler.java | 51 +++++---------
.../adaptive/DefaultStateTransitionManager.java | 24 +++----
.../runtime/scheduler/adaptive/Executing.java | 50 +++++++------
.../EnforceMinimalIncreaseRescalingController.java | 48 -------------
...nforceParallelismChangeRescalingController.java | 41 -----------
.../scalingpolicy/RescalingController.java | 38 ----------
.../adaptive/AdaptiveSchedulerClusterITCase.java | 3 +
.../scheduler/adaptive/AdaptiveSchedulerTest.java | 29 ++++----
.../DefaultStateTransitionManagerTest.java | 60 ++++++++--------
.../runtime/scheduler/adaptive/ExecutingTest.java | 82 ++++++++++++++++++++--
.../adaptive/StateTrackingMockExecutionGraph.java | 5 +-
...orceMinimalIncreaseRescalingControllerTest.java | 69 ------------------
...ceParallelismChangeRescalingControllerTest.java | 61 ----------------
17 files changed, 256 insertions(+), 420 deletions(-)
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/scalingpolicy/EnforceMinimalIncreaseRescalingController.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/scalingpolicy/EnforceParallelismChangeRescalingController.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/scalingpolicy/RescalingController.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/scalingpolicy/EnforceMinimalIncreaseRescalingControllerTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/scalingpolicy/EnforceParallelismChangeRescalingControllerTest.java
