Github user zentol commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5782#discussion_r177804309
  
    --- Diff: 
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphMetricsTest.java
 ---
    @@ -193,6 +197,8 @@ public void testExecutionGraphRestartTimeMetric() 
throws JobException, IOExcepti
     
                                assertTrue(currentRestartingTime >= 
previousRestartingTime);
                                previousRestartingTime = currentRestartingTime;
    +                           // add some pause to the let 
currentRestartingTime increase
    +                           Thread.sleep(1L);
    --- End diff --
    
    same as above


---

Reply via email to