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