Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5309#discussion_r163571196
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCacheTest.java
---
@@ -228,10 +246,10 @@ public void testConcurrentAccess() throws Exception {
Collection<AccessExecutionGraph> allExecutionGraphs =
allExecutionGraphFutures.get();
--- End diff --
Doesn't need to be changed but `ExecutorCompletionService` does something
similar.
---