Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4933#discussion_r148399427
--- 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 --
Not really, because we reuse the message in the line below. Moreover, the
logging statement is error and thus, will be evaluated in almost all cases.
What one could argue is whether normal string concatenation wouldn't be faster
than `String.format`.
---
