Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/4933#discussion_r148306365 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java --- @@ -844,7 +844,7 @@ else if (current == CANCELING || current == RUNNING || current == DEPLOYING) { // failing in the meantime may happen and is no problem. // anything else is a serious problem !!! if (current != FAILED) { - String message = String.format("Asynchronous race: Found state %s after successful cancel call.", state); + String message = String.format("Asynchronous race: Found %s in state %s after successful cancel call.", vertex.getTaskNameWithSubtaskIndex(), state); LOG.error(message); --- End diff -- nit: slf4j's `{}` placeholders should be used.
---