zlzhang0122 created FLINK-26788: ----------------------------------- Summary: 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.14.4, 1.13.6, 1.12.7 Reporter: zlzhang0122 Fix For: 1.15.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} . -- This message was sent by Atlassian Jira (v8.20.1#820001)