Older versions of flink were incompatible with the Scala specific record classes generated from AvroHugger.
https://issues.apache.org/jira/browse/FLINK-12501 Flink 1.10 apparently is fixing this. I am currently using 1.10.1. However, still experience thus problem https://stackoverflow.com/questions/62637009/flink-use-confluent-schema-registry-for-avro-serde of: AvroRuntimeException: Not a Specific class What is still wrong here? Best, Georg
