Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5443#discussion_r167412925
--- 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 --
we could replace the mocks in this class with VoidBackPressureStatsTracker
/ lambda implementations.
---
