dataformats-lib/src/main/java/com/streamsets/service/lib/ShimUtil.java
public static DataParserException convert(
      com.streamsets.pipeline.lib.parser.DataParserException original
  ) {
    if(original instanceof com.streamsets.pipeline.lib.parser.RecoverableDataParserException) {
      return new RecoverableDataParserException(
        ((com.streamsets.pipeline.lib.parser.RecoverableDataParserException) original).getUnparsedRecord(),
        original.getErrorCode(),
        original.getParams()
      );
    }

    return new DataParserException(
      original.getErrorCode(),
      original.getParams()
    );
  }
public static DataParserException convert(
      com.streamsets.pipeline.lib.parser.DataParserException original
  ) {
    if(original instanceof com.streamsets.pipeline.lib.parser.RecoverableDataParserException) {
      return new RecoverableDataParserException(
        ((com.streamsets.pipeline.lib.parser.RecoverableDataParserException) original).getUnparsedRecord(),
        original.getErrorCode(),
        original.getParams()
      );
    }

    return new DataParserException(
      original.getErrorCode(),
      original.getParams()
    );
  }
public static DataParserException convert ( com . streamsets . pipeline . lib . parser . DataParserException original ) { if ( original instanceof com . streamsets . pipeline . lib . parser . RecoverableDataParserException ) { return new RecoverableDataParserException ( ( ( com . streamsets . pipeline . lib . parser . RecoverableDataParserException ) original ) . getUnparsedRecord ( ) , original . getErrorCode ( ) , original . getParams ( ) ) ; } return new DataParserException ( original . getErrorCode ( ) , original . getParams ( ) ) ; }
Change package name for DataParserException.

@param original Original exception from *.lib.* package
@return New exception from *.api.* package
Change package name for DataParserException .