This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 32a195e9d50309db654206c7e43dc82906aa2021 Author: Chesnay Schepler <[email protected]> AuthorDate: Thu Jun 11 19:00:30 2020 +0200 [FLINK-17977][runtime] Log initiation of savepoint operations --- .../main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java index 1a10d6b..95eec11 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java @@ -747,6 +747,8 @@ public abstract class SchedulerBase implements SchedulerNG { "default via key '" + CheckpointingOptions.SAVEPOINT_DIRECTORY.key() + "'."); } + log.info("Triggering {}savepoint for job {}.", cancelJob ? "cancel-with-" : "", jobGraph.getJobID()); + if (cancelJob) { checkpointCoordinator.stopCheckpointScheduler(); } @@ -857,6 +859,8 @@ public abstract class SchedulerBase implements SchedulerNG { "default via key '" + CheckpointingOptions.SAVEPOINT_DIRECTORY.key() + "'.")); } + log.info("Triggering stop-with-savepoint for job {}.", jobGraph.getJobID()); + // we stop the checkpoint coordinator so that we are guaranteed // to have only the data of the synchronous savepoint committed. // in case of failure, and if the job restarts, the coordinator
