You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2021/11/26 17:10:58 UTC
[flink] branch release-1.14 updated (0a5481b -> 0258419)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 0a5481b [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperStateHandleStore in case of unstable connection.
add 0258419 [FLINK-24789][runtime] Close CheckpointCleaner after checkpoint services in `DefaultScheduler#closeAsync()` and `AdaptiveScheduler#closeAsync()`.'
No new revisions were added by this update.
Summary of changes:
.../apache/flink/util/concurrent/FutureUtils.java | 2 +-
.../flink/runtime/scheduler/DefaultScheduler.java | 3 +
.../runtime/scheduler/DefaultSchedulerFactory.java | 2 +
.../flink/runtime/scheduler/SchedulerBase.java | 8 +-
.../scheduler/adaptive/AdaptiveScheduler.java | 9 +-
.../adaptive/AdaptiveSchedulerFactory.java | 2 +
.../runtime/scheduler/DefaultSchedulerTest.java | 98 ++++++++++++++++++++++
.../runtime/scheduler/SchedulerTestingUtils.java | 9 ++
.../adaptive/AdaptiveSchedulerBuilder.java | 9 ++
.../scheduler/adaptive/AdaptiveSchedulerTest.java | 29 +++++++
10 files changed, 163 insertions(+), 8 deletions(-)