[ https://issues.apache.org/jira/browse/FLINK-1593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14365264#comment-14365264 ]
Robert Metzger commented on FLINK-1593: --------------------------------------- Sorry, I resolved the issue. The {{CoInvokable.java}} didn't properly forward the exceptions. I'll include the fix in my next pull request. > Improve exception handling in the Streaming runtime > --------------------------------------------------- > > Key: FLINK-1593 > URL: https://issues.apache.org/jira/browse/FLINK-1593 > Project: Flink > Issue Type: Improvement > Components: Streaming > Reporter: Gyula Fora > Assignee: Gyula Fora > Fix For: 0.9 > > > The current exception handling logic is not very helpful when trying to debug > an application. In many cases with serialization/user code or other > exceptions, the error is just logged and not propagated properly. This should > mainly be fixed in the StreamInvokables. > Some improvements that could be made: > -Serialization/Deserialiaztion and other system errors should be propagated > instead of just silently logged > -User code exceptions should be better handled, for instance I think it would > be helpful to log them to INFO so that users can instantly see it. -- This message was sent by Atlassian JIRA (v6.3.4#6332)