Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5443#discussion_r167501726 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/JobVertexBackPressureHandlerTest.java --- @@ -57,7 +57,7 @@ public void testGetPaths() { @Test public void testResponseNoStatsAvailable() throws Exception { ExecutionJobVertex jobVertex = mock(ExecutionJobVertex.class); - BackPressureStatsTracker statsTracker = mock(BackPressureStatsTracker.class); + BackPressureStatsTrackerImpl statsTracker = mock(BackPressureStatsTrackerImpl.class); --- End diff -- Will change it.
---