John Lonergan created FLINK-14174:
-------------------------------------
Summary: Don't swallow exception when rethrowing type mismatches with side outputs
Key: FLINK-14174
URL:
https://issues.apache.org/jira/browse/FLINK-14174 Project: Flink
Issue Type: Improvement
Components: API / DataStream
Affects Versions: 1.9.0, 1.8.1
Reporter: John Lonergan
The change made by
https://github.com/apache/flink/pull/4663/files swallows the original exception.
Whilst I am in favour of adding additional helpful tips (which was the purpose of FLINK-4663) I don't agree with throwing away or masking causal exceptions.
IMHO the correct approach is to add the helpful hint as the first arg to "new ExceptionInChainedOperatorException(msg, ex)" and pass the original class cast ex as the cause.
Ie change this ..
https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java#L672--
This message was sent by Atlassian Jira
(v8.3.4#803005)