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 your problem.
[1] https://issues.apache.org/jira/browse/FLINK-28653 On Tue, Oct 11, 2022 at 3:31 PM Sucheth S <suchet...@gmail.com> 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 > -- Best, Hangxiang.
