RE: DebeziumAvroDeserializationSchema

[lan tran]

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     On 2022/04/22 03:14:43 lan tran wrote: > Hi team,  >   > Currently, I did not see this functions in PyFlink, therefore any suggestion > on using this on PyFlink ?  >   > Best,  > Quynh. > > > > Sent from [Mail](https://go.microsoft.com/fwlink/?LinkId=550986) for Windows > > > > Sent from Mail for Windows