[flink] branch release-1.9 updated: [FLINK-14049] [coordination] Add task name to error message for failed partition updates.

[se...@apache.org]

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

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


The following commit(s) were added to refs/heads/release-1.9 by this push:
     new abaa901  [FLINK-14049] [coordination] Add task name to error message for failed partition updates.
abaa901 is described below

commit abaa901adc6a115756b2099339d80c992ceb14f0
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Wed Sep 11 09:43:17 2019 +0200

    [FLINK-14049] [coordination] Add task name to error message for failed partition updates.
    
    This closes #9670
---
 .../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 209c490..c070e4e 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
@@ -1392,8 +1392,8 @@ public class Execution implements AccessExecution, Archiveable<ArchivedExecution
 				(ack, failure) -> {
 					// fail if there was a failure
 					if (failure != null) {
-						fail(new IllegalStateException("Update task on TaskManager " + taskManagerLocation +
-							" failed due to:", failure));
+						fail(new IllegalStateException("Update to task [" + getVertexWithAttempt() +
+							"] on TaskManager " + taskManagerLocation + " failed", failure));
 					}
 				}, getVertex().getExecutionGraph().getJobMasterMainThreadExecutor());
 		}