Github user yuqi1129 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6092#discussion_r191340849
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -1173,9 +1179,10 @@ public void startCheckpointScheduler() {
stopCheckpointScheduler();
periodicScheduling = true;
+ long initialDelay =
schedulerInitialDelayGenerator.nextLong(
+ minPauseBetweenCheckpointsNanos / 1_000_000,
baseInterval);
--- End diff --
Any place to check the value `minPauseBetweenCheckpointsNanos / 1_000_000`
is less or equal than baseInterval?
---