[FLINK-9350] Parameter baseInterval has wrong check message in CheckpointCoordinator constructor
This closes #6002. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4e937aa5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4e937aa5 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4e937aa5 Branch: refs/heads/release-1.5 Commit: 4e937aa5853f8dbbdb7572519310bf123238ff88 Parents: 3b22b48 Author: yanghua <[email protected]> Authored: Mon May 14 10:42:01 2018 +0800 Committer: Tzu-Li (Gordon) Tai <[email protected]> Committed: Tue May 15 16:48:01 2018 +0800 ---------------------------------------------------------------------- .../org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/4e937aa5/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ---------------------------------------------------------------------- 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 b3ce577..55e1ffe 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 @@ -199,7 +199,7 @@ public class CheckpointCoordinator { // sanity checks checkNotNull(checkpointStateBackend); - checkArgument(baseInterval > 0, "Checkpoint timeout must be larger than zero"); + checkArgument(baseInterval > 0, "Checkpoint base interval must be larger than zero"); checkArgument(checkpointTimeout >= 1, "Checkpoint timeout must be larger than zero"); checkArgument(minPauseBetweenCheckpoints >= 0, "minPauseBetweenCheckpoints must be >= 0"); checkArgument(maxConcurrentCheckpointAttempts >= 1, "maxConcurrentCheckpointAttempts must be >= 1");
