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:09:27 UTC
[flink] branch master updated (3d7ad08 -> e42890f)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 3d7ad08 [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperStateHandleStore in case of unstable connection.
add e42890f [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(-)