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

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

commit 3c84c058c67a02671cf325b27576b6faaba1d836
Author: ifndef-SleePy <[email protected]>
AuthorDate: Thu Sep 19 21:23:35 2019 +0800

    [hotfix] Correct code style of CheckpointCoordinator
---
 .../org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
index f30b135..e7c7e17 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
@@ -1249,7 +1249,7 @@ public class CheckpointCoordinator {
        }
 
        /**
-        * If too many checkpoints are currently in progress, we need to mark 
that a request is queued
+        * If too many checkpoints are currently in progress, we need to mark 
that a request is queued.
         *
         * @throws CheckpointException If too many checkpoints are currently in 
progress.
         */
@@ -1265,7 +1265,7 @@ public class CheckpointCoordinator {
        }
 
        /**
-        * Make sure the minimum interval between checkpoints has passed
+        * Make sure the minimum interval between checkpoints has passed.
         *
         * @throws CheckpointException If the minimum interval between 
checkpoints has not passed.
         */

Reply via email to