Hi,

I use flink-scala version 1.9.1 and scala 2.12.10, and I defined a data
type which is a bit more complex: it has a list in it and even a
dictionary. When I try to use a custom map I got this error:

INFO  org.apache.flink.api.java.typeutils.TypeExtractor - class A  does not
contain a setter for field fields
INFO  org.apache.flink.api.java.typeutils.TypeExtractor - class A cannot be
used as a POJO type because not all fields are valid POJO fields, and must
be processed as GenericType. Please read the Flink documentation on "Data
Types & Serialization" for details of the effect on performance.

Is there a fix for this? Or a workaround?

Thank you,
Alex

Reply via email to