This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch release-2.0
in repository https://gitbox.apache.org/repos/asf/flink.git
from 3b2f94ecf2b [FLINK-37206][Runtime] Fix initialization of batching
timer service in async state operators (#26092)
new 1ff7433bcca [FLINK-37232][runtime] Fix for broken synchronization
assumption on the AdaptiveScheduler's side introduced by FLIP-272
new 4fbed74d111 [hotfix] Disable cooldown period to speed up test in
UpdateJobResourceRequirementsITCase
The 2 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/adaptive/AdaptiveScheduler.java | 4 +-
.../runtime/scheduler/adaptive/Executing.java | 6 +-
.../scheduler/adaptive/FailureResultUtil.java | 2 +-
.../runtime/scheduler/adaptive/Restarting.java | 42 +++++++++---
.../scheduler/adaptive/StateTransitions.java | 11 ++--
.../scheduler/adaptive/AdaptiveSchedulerTest.java | 4 +-
.../runtime/scheduler/adaptive/ExecutingTest.java | 25 ++++---
.../scheduler/adaptive/MockRestartingContext.java | 14 ++++
.../runtime/scheduler/adaptive/RestartingTest.java | 72 +++++++++++++++-----
.../scheduler/adaptive/StopWithSavepointTest.java | 9 ++-
.../UpdateJobResourceRequirementsITCase.java | 77 +++++++++++++++++++++-
11 files changed, 218 insertions(+), 48 deletions(-)
