Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5105#discussion_r156402616
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/MockEnvironment.java
---
@@ -101,7 +90,8 @@
private final ClassLoader userCodeClassLoader;
- private TaskEventDispatcher taskEventDispatcher =
mock(TaskEventDispatcher.class);
+ private TaskEventDispatcher taskEventDispatcher = mock
+ (TaskEventDispatcher.class);
--- End diff --
except for the unnecessary line break, this could also easily be replaced
by `new TaskEventDispatcher();` instead
---
