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

[ch...@apache.org]

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

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


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

commit 5ba6525db731aa62a770a9a7971b8a1cbf12d9fb
Author: Chesnay Schepler <ch...@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);