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?


---

Reply via email to