[ 
https://issues.apache.org/jira/browse/FLINK-12501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151921#comment-17151921
 ] 

Georg Heiler commented on FLINK-12501:
--------------------------------------

I am very new to Flink so if you already know what needs to be changed and do 
not want to offer quite some guidance it would be awesome if you could provide 
the fix.

> AvroTypeSerializer does not work with types generated by avrohugger
> -------------------------------------------------------------------
>
>                 Key: FLINK-12501
>                 URL: https://issues.apache.org/jira/browse/FLINK-12501
>             Project: Flink
>          Issue Type: Bug
>          Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
>            Reporter: Aljoscha Krettek
>            Assignee: Aljoscha Krettek
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.9.1, 1.10.0
>
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> The main problem is that the code in {{SpecificData.createSchema()}} tries to 
> reflectively read the {{SCHEMA$}} field, that is normally there in Avro 
> generated classes. However, avrohugger generates this field in a companion 
> object, which the reflective Java code will therefore not find.
> This is also described in these ML threads:
>  * 
> [https://lists.apache.org/thread.html/5db58c7d15e4e9aaa515f935be3b342fe036e97d32e1fb0f0d1797ee@%3Cuser.flink.apache.org%3E]
>  * 
> [https://lists.apache.org/thread.html/cf1c5b8fa7f095739438807de9f2497e04ffe55237c5dea83355112d@%3Cuser.flink.apache.org%3E]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to