There's no alternative to Kryo for generic types, apart from
implementing your Flink serializer (but technically at that point the
type is no longer treated as a generic type).
enableForAvro only forces Avro to be used for POJO types.
On 11/10/2022 09:29, Sucheth S wrote:
Hello,
How to avoid flink's kryo serializer for GenericTypes ? Kryo is having
some performance issues.
Tried below but no luck.
env.getConfig().disableForceKryo();
env.getConfig().enableForceAvro();
Tried this - env.getConfig().disableGenericTypes();
getting - Generic types have been disabled in the ExecutionConfig and type
org.apache.avro.generic.GenericRecord is treated as a generic type
Regards,
Sucheth Shivakumar
website: https://sucheths.com
mobile : +1(650)-576-8050
San Mateo, United States
