Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6092#discussion_r200065877
--- 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 --
Could we replace `schedulerInitialDelayGenerator` with `long initialDelay =
ThreadLocalRandom.current().nextLong(minPauseBetweenCheckpointsNanos /
1_000_000, baseInterval);`? That way we would not have to use `RandomUtils`.
---
