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?
---