Flink falls back on to kryo serializer for GenericTypes

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

Deserialize avro message without reader schema.

Hi, I'm trying to deserialize avro messages from the kafka topic as a consumer. As a kafka consumer, I do not want to hold the reader schema on my end. Is there a way to deserialize avro messages to GenericRecord without providing the reader schema ? Regards, Sucheth Shivakumar website : https:

Re: Flink config driven tool ?

You are just spamming the inbox by sending these emails. You can just ignore sending those emails if it isn't adding any value. Regards, Sucheth Shivakumar website : https://sucheths.com mobile : +1(650)-576-8050 San Mateo, United States On Wed, Jun 15, 2022 at 1:41 PM sri hari kali charan Tumm

Re: Apache flink doesn't work with avro kafka topic with multiple event types

ster/docs/connectors/table/formats/raw/ > > Best regards, > > Qingsheng > > On Sun, Jun 12, 2022 at 12:53 PM Sucheth S wrote: > > > > Hi, > > > > Apache Flink doesn't work with Avro serialized kafka topic with multiple > event types ( > > To

Apache flink doesn't work with avro kafka topic with multiple event types

Hi, Apache Flink doesn't work with Avro serialized kafka topic with multiple event types ( TopicRecordNameStrategy for subject ) Is there a way to read a generic record from avro serialized kafka topic which can have messages with different schemas, basically TopicRecordNameStrategy for the subje

Re: filesink part files roll over

Thank you! On Mon, Jun 6, 2022 at 2:57 AM Qingsheng Ren wrote: > Hi Sucheth, > > Please see https://issues.apache.org/jira/browse/FLINK-27910 > > Best, > > Qingsheng > > > On Jun 5, 2022, at 23:21, Sucheth S wrote: > > > > Hi, > > > >

Re: Need help to join Apache Flink community on.Slack

, Jun 5, 2022 at 6:06 PM Sucheth S wrote: > >> Hello Jing, >> >> Can you please add me - suchet...@gmail.com >> >> >> On Sun, Jun 5, 2022 at 9:02 AM sri hari kali charan Tummala < >> kali.tumm...@gmail.com> wrote: >> >>> Hi Jing, >&g

Re: Need help to join Apache Flink community on.Slack

Hello Jing, Can you please add me - suchet...@gmail.com On Sun, Jun 5, 2022 at 9:02 AM sri hari kali charan Tummala < kali.tumm...@gmail.com> wrote: > Hi Jing, > > Please add me kali.tumm...@gmail.com. > > Thanks > Sri > > On Sat, Jun 4, 2022 at 4:47 PM Jing Ge wrote: > >> Hi Santhosh, >> >> j

filesink part files roll over

Hi, Can someone please help me with this please - https://stackoverflow.com/q/72496963/9125940 ? Regards, Sucheth Shivakumar website : https://sucheths.com mobile : +1(650)-576-8050 San Mateo, United States