Repository: flink Updated Branches: refs/heads/master 0c42d258e -> 9ab494a73
[hotfix] properly encapsulate the original exception in JobClient This closes #2890 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9ab494a7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9ab494a7 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9ab494a7 Branch: refs/heads/master Commit: 9ab494a73b02ff6bb634701226e49a1f42f05efb Parents: 0c42d25 Author: Nico Kruber <[email protected]> Authored: Fri Nov 25 16:55:05 2016 +0100 Committer: Robert Metzger <[email protected]> Committed: Fri Dec 9 18:02:18 2016 +0100 ---------------------------------------------------------------------- .../src/main/java/org/apache/flink/runtime/client/JobClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/9ab494a7/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClient.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClient.java b/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClient.java index 132d74c..9f0c573 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClient.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClient.java @@ -222,7 +222,7 @@ public class JobClient { allURLs[pos++] = blobClient.getURL(blobKey); } catch (Exception e) { blobClient.shutdown(); - throw new JobRetrievalException(jobID, "Failed to download BlobKey " + blobKey); + throw new JobRetrievalException(jobID, "Failed to download BlobKey " + blobKey, e); } }
