Hi Georg,

unfortunately, it seems I only fixed the issue for AvroSerializer and not for AvroDeserializationSchema. I created a new issue (which is a clone of the old one) to track this [1]. The fix should be very simple since it's the same issue.

Best,
Aljoscha

[1] https://issues.apache.org/jira/browse/FLINK-18478

On 01.07.20 09:11, Till Rohrmann wrote:
Hi Georg,

I'm pulling in Aljoscha who might know more about the problem you are
describing.

Cheers,
Till

On Mon, Jun 29, 2020 at 10:21 PM Georg Heiler <georg.kf.hei...@gmail.com>
wrote:

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




Reply via email to