Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4761#discussion_r154023982
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -671,7 +671,7 @@ else if (current == ExecutionState.CANCELING) {
jobConfiguration, taskConfiguration,
userCodeClassLoader,
memoryManager, ioManager,
broadcastVariableManager,
accumulatorRegistry, kvStateRegistry,
inputSplitProvider,
- distributedCacheEntries, writers, inputGates,
+ distributedCacheEntries, writers, inputGates,
network.getTaskEventDispatcher(),
--- End diff --
wow. Could you reformat this one with one parameter per line?
---
