You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/09/22 12:44:25 UTC
[flink] branch master updated: [FLINK-29378][coordination] Improve logging of failed execution state transitions
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 <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);