[ 
https://issues.apache.org/jira/browse/FLINK-26788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540000#comment-17540000
 ] 

Yun Gao commented on FLINK-26788:
---------------------------------

Merged on master via 0eda2cc35a7185592129df8d4b004acc7a60d3bf

Merged on release-1.15 via 3171cb019df2ea14bae9057e7da0113b55967bef

Merged on release-1.14 via 3be78d01a2c36cb89a91d43f08155a17ffb6cd7e

> AbstractDeserializationSchema should add cause when thow a 
> FlinkRuntimeException
> --------------------------------------------------------------------------------
>
>                 Key: FLINK-26788
>                 URL: https://issues.apache.org/jira/browse/FLINK-26788
>             Project: Flink
>          Issue Type: Improvement
>          Components: API / Core
>    Affects Versions: 1.12.7, 1.13.6, 1.14.4
>            Reporter: zlzhang0122
>            Assignee: Ran Tao
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.16.0
>
>
> In the constructor method of the class AbstractDeserializationSchema which 
> has no parameters, it throw a FlinkRuntimeException, but it has no cause, 
> which will lead more difficult to find the root cause, we should use the 
> {code:java}
> FlinkRuntimeException(String message, Throwable cause) {code}
> instead of 
> {code:java}
> FlinkRuntimeException(String message) {code}
> see 
> [here|https://github.com/apache/flink/blob/ff3336266e5ea6c440916c1ae4ab9440e2ceb0bf/flink-core/src/main/java/org/apache/flink/api/common/serialization/AbstractDeserializationSchema.java#L107].
>     
>  



--
This message was sent by Atlassian Jira
(v8.20.7#820007)

Reply via email to