[hotfix] properly encapsulate the original exception in JobClient

This closes apache#2890
fullcontact · Dec 9, 2016 · 9ab494a · 9ab494a
1 parent 0c42d25
commit 9ab494a
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -222,7 +222,7 @@ public static ClassLoader retrieveClassLoader(
  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);
  }
  }