Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5107#discussion_r154128004 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java --- @@ -246,5 +258,11 @@ protected JobManagerRunner createJobManagerRunner( return jobManagerRunner; } + + @Override + protected void runAsync(final Runnable runnable) { --- End diff -- I think if I can set Akka's `CallingThreadDispatcher`, this is not needed.
---