You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/07/25 13:07:00 UTC

[jira] [Created] (FLINK-28675) AvroDeserializationSchema should eagerly validate that class is SpecificRecord

Chesnay Schepler created FLINK-28675:
----------------------------------------

             Summary: AvroDeserializationSchema should eagerly validate that class is SpecificRecord
                 Key: FLINK-28675
                 URL: https://issues.apache.org/jira/browse/FLINK-28675
             Project: Flink
          Issue Type: Improvement
          Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
    Affects Versions: 1.15.1
            Reporter: Chesnay Schepler
             Fix For: 1.16.0


The AvroDeserializationSchema supports both generic and specific records, with dedicated factory methods.

It does however not validate in any way whether the classes passed to the factories methods are actually generic/specific records respectively, which can result in Flink attempting to read generic records (and failing with an NPE) even though the user told us to read specific records.

We should validate this eagerly and fail early.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)