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
Hi Sucheth.
It's related to how you defined your GenericTypes.
You may still need to give some hints to flink if you are using complicated
generic types so what you tried may not be enough.
Could you share your generic type object ?
BTW, Maybe you could refer to [1] which I think it's similar to yo
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