[ https://issues.apache.org/jira/browse/FLINK-3691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Fabian Hueske closed FLINK-3691. -------------------------------- Resolution: Implemented Fix Version/s: 1.1.0 Thanks for the contribution, [~Gna Phetsarath]! Implemented for 1.1.0 with 5c4cb452f06e4333be475b30779eaac2628abf51 > 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 > Fix For: 1.1.0 > > > 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)