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