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)
