You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2019/10/28 08:22:33 UTC
[flink] 03/08: [hotfix] Correct code style of CheckpointCoordinator
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 <mm...@gmail.com>
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.
*/