[FLINK-26788] AbstractDeserializationSchema should add cause when throwing a FlinkRuntimeException

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.12.7, 1.13.6, 1.14.4
• Fix Version/s: 1.14.5, 1.15.1, 1.16.0
• Component/s: API / Core
• Labels: pull-request-available
• Assignee: Ran Tao
• Reporter: zlzhang0122
• Created: 21/Mar/22 15:53
• Updated: 17/Jun/22 13:11
• Resolved: 20/May/22 09:08

Description

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 

FlinkRuntimeException(String message, Throwable cause) 

instead of 

FlinkRuntimeException(String message) 

see here.    

 

Issue Links

• links to: GitHub Pull Request #19241