Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-26788

AbstractDeserializationSchema should add cause when throwing a FlinkRuntimeException

    XMLWordPrintableJSON

Details

    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.    

       

      Attachments

        Issue Links

          Activity

            People

              lemonjing Ran Tao
              zlzhang0122 zlzhang0122
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: