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?


---

Reply via email to