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?
---