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 77edff62032 [FLINK-37213][table-runtime] Improve performance of
unbounded OVER aggregations
new 5b1d0081b47 [FLINK-37232][runtime] Fix for broken synchronization
assumption on the AdaptiveScheduler's side introduced by FLIP-272
new cb6c06d7f98 [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(-)
