You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/09/21 07:41:24 UTC
[flink] 01/04: [FLINK-10375] Added wrapped exception as cause
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-1.6
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 4529e377eb23155f53fe1c1dd86830098313bc4f
Author: Mike Pedersen <mp...@enversion.dk>
AuthorDate: Thu Sep 20 13:53:56 2018 +0200
[FLINK-10375] Added wrapped exception as cause
This closes #6719.
---
.../runtime/operators/chaining/ExceptionInChainedStubException.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ExceptionInChainedStubException.java b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ExceptionInChainedStubException.java
index 11b5bf0..e7cebc5 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ExceptionInChainedStubException.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ExceptionInChainedStubException.java
@@ -33,7 +33,7 @@ public class ExceptionInChainedStubException extends RuntimeException {
public ExceptionInChainedStubException(String taskName, Exception wrappedException) {
- super();
+ super("Exception in chained task '" + taskName + "'", exceptionUnwrap(wrappedException));
this.taskName = taskName;
this.exception = wrappedException;
}