Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6092#discussion_r191341746
--- 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 --
@yuqi1129 please see the constructor's [code
segment](https://github.com/yanghua/flink/blob/1eb432833bf2dd23187194500b6e1c6523f30605/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java#L218)
---
