You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ar...@apache.org on 2021/02/09 18:23:29 UTC

[flink] 02/02: [hotfix][checkpointing] Update javadoc for CompletedCheckpointStore.shutdown()

This is an automated email from the ASF dual-hosted git repository.

arvid pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit ced0fdddc31114516b94c97ae021aceeb53bb991
Author: Roman Khachatryan <kh...@gmail.com>
AuthorDate: Sat Feb 6 13:34:12 2021 +0100

    [hotfix][checkpointing] Update javadoc for CompletedCheckpointStore.shutdown()
---
 .../org/apache/flink/runtime/checkpoint/CompletedCheckpointStore.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStore.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStore.java
index 789fb9b..10c5c07 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStore.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStore.java
@@ -92,6 +92,7 @@ public interface CompletedCheckpointStore {
      * or kept.
      *
      * @param jobStatus Job state on shut down
+     * @param checkpointsCleaner that will cleanup copmpleted checkpoints if needed
      */
     void shutdown(JobStatus jobStatus, CheckpointsCleaner checkpointsCleaner) throws Exception;