[
https://issues.apache.org/jira/browse/FLINK-10695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16666490#comment-16666490
]
ASF GitHub Bot commented on FLINK-10695:
----------------------------------------
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]
> "Cannot load user class" errors should set the underlying
> ClassNotFoundException as their cause
> -----------------------------------------------------------------------------------------------
>
> Key: FLINK-10695
> URL: https://issues.apache.org/jira/browse/FLINK-10695
> Project: Flink
> Issue Type: Improvement
> Components: Streaming
> Reporter: Max Feng
> Assignee: Max Feng
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.7.0
>
>
> In {{StreamConfig#getStreamOperator}}, {{ClassNotFoundException}} is
> propagated as {{StreamTaskException}} but does not set the underlying
> {{ClassNotFoundException}} as the cause of the {{StreamTaskException}}.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
