You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2016/12/09 17:02:26 UTC

flink git commit: [hotfix] properly encapsulate the original exception in JobClient

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 <ni...@data-artisans.com>
Authored: Fri Nov 25 16:55:05 2016 +0100
Committer: Robert Metzger <rm...@apache.org>
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);
 				}
 			}