Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r159865703
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -669,31 +676,14 @@ else if (current == ExecutionState.CANCELING) {
Environment env = new RuntimeEnvironment(
jobId, vertexId, executionId, executionConfig,
taskInfo,
jobConfiguration, taskConfiguration,
userCodeClassLoader,
- memoryManager, ioManager,
broadcastVariableManager,
+ memoryManager, ioManager,
broadcastVariableManager, taskStateManager,
--- End diff --
please reformat this call
---
