Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/4933#discussion_r148498481
--- 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 --
Ok
---
