Hi Quynh, I have added an example on how to use AvroRowDeserializationSchema in Python DataStream API in [1]. Please take a look at if that helps for you~
Regards, Dian [1] https://github.com/apache/flink/blob/release-1.15/flink-python/pyflink/examples/datastream/formats/avro_format.py On Fri, Apr 22, 2022 at 7:24 PM Dian Fu <dian0511...@gmail.com> wrote: > Hi Quynh, > > Could you show some sample code on how you use it? > > Regards, > Dian > > On Fri, Apr 22, 2022 at 1:42 PM lan tran <indigoblue7...@gmail.com> wrote: > >> Wonder if this is a bug or not but if I use >> *AvroRowDeserializationSchema,* >> >> In PyFlink the error still occure ? >> >> py4j.protocol.Py4JError: An error occurred while calling >> None.org.apache.flink.formats.avro.AvroRowDeserializationSchema. Trace: >> >> org.apache.flink.api.python.shaded.py4j.Py4JException: Constructor >> org.apache.flink.formats.avro.AvroRowDeserializationSchema([class >> org.apache.avro.Schema$RecordSchema]) does not exist >> >> Therefore, please help check. Thanks >> Best, >> Quynh >> >> >> >> >> >> Sent from Mail <https://go.microsoft.com/fwlink/?LinkId=550986> for >> Windows >> >> >> >> *From: *lan tran <indigoblue7...@gmail.com> >> *Sent: *Thursday, April 21, 2022 1:43 PM >> *To: *user@flink.apache.org >> *Subject: *AvroRowDeserializationSchema >> >> >> >> Hi team, >> >> I want to implement AvroRowDeserializationSchema when consume data from >> Kafka, however from the documentation, I did not understand what are >> avro_schema_string and record_class ? I would be great if you can give me >> the example on this (I only have the example on Java, however, I was doing >> it using PyFlink ). >> >> As my understanding avro_schema_string is schema_registry_url ? Does it >> support this >> 'debezium-avro-confluent.schema-registry.url'='{schema_registry_url}' like >> in TableAPI ? >> >> Best, >> Quynh. >> >> Sent from Mail <https://go.microsoft.com/fwlink/?LinkId=550986> for >> Windows >> >> >> >> >> >
