[
https://issues.apache.org/jira/browse/FLINK-3691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15223841#comment-15223841
]
Robert Metzger commented on FLINK-3691:
---------------------------------------
Feel free to open a pull request for allowing to read GenericRecords from Avro.
I thought that our current implementation already supports GenericRecords.
There are certainly tests ensuring that Flink's serialization framework is able
to handle GenericRecords. Sadly, there is no test case for reading
GenericRecord with the InputFormat.
> Extend AvroInputFormat to support Avro GenericRecord
> ----------------------------------------------------
>
> Key: FLINK-3691
> URL: https://issues.apache.org/jira/browse/FLINK-3691
> Project: Flink
> Issue Type: Improvement
> Components: Core
> Reporter: Gna Phetsarath
> Priority: Minor
>
> Extend AvroInputFormat to support Avro GenericRecord:
> Sometimes the calling application will have access to the schema but not the
> implementing class for Avro files.
> Using a GenericDatumReader will allow the AvroInput format to read records in
> the Avro Generic Record Format.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
