Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6082 Thanks for the update @tragicjun. I had a look at the changes. I think the logic does still not cover all cases that we want to cover. Avro has the following types: `RECORD, ENUM, ARRAY, MAP, UNION, FIXED, STRING, BYTES, INT, LONG, FLOAT, DOUBLE, BOOLEAN, NULL` And they should all be covered in the converter and ser/deser schemes. Would it be ok for you if I try to simplify the logic a bit and build on top of your commits?
---