asfgit closed pull request #6945: [FLINK-10695] Cannot load user class errors
set underlying cause
URL: https://github.com/apache/flink/pull/6945
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java
index 85c676c9b1a..457eee274aa 100644
---
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java
+++
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java
@@ -233,7 +233,7 @@ public void setStreamOperator(StreamOperator<?> operator) {
"\nClass was actually
found in classloader - deserialization issue." :
"\nClass not resolvable
through given classloader.");
- throw new StreamTaskException(exceptionMessage);
+ throw new StreamTaskException(exceptionMessage, e);
}
catch (Exception e) {
throw new StreamTaskException("Cannot instantiate user
function.", e);
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
