[flink] branch master updated: [FLINK-29378][coordination] Improve logging of failed execution state transitions

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 5766d50dc14 [FLINK-29378][coordination] Improve logging of failed 
execution state transitions
5766d50dc14 is described below

commit 5766d50dc1401b1269ec83e670c2d21257e20fc5
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Wed Sep 21 10:50:04 2022 +0200

    [FLINK-29378][coordination] Improve logging of failed execution state 
transitions
---
 .../main/java/org/apache/flink/runtime/executiongraph/Execution.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
index f6de9059869..3323f453373 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
@@ -1226,8 +1226,8 @@ public class Execution
             } else {
                 String message =
                         String.format(
-                                "Concurrent unexpected state transition of 
task %s to %s while deployment was in progress.",
-                                getVertexWithAttempt(), currentState);
+                                "Concurrent unexpected state transition of 
task %s from %s (expected %s) to %s while deployment was in progress.",
+                                getAttemptId(), currentState, from, to);
 
                 LOG.debug(message);