Thank Dian !! Very appreciate this.

However, I have another questions related to this. In current version or any updating in future, does DataStream support DebeziumAvroRowDeserializationSchema and DebeziumJsonRowDeserializationSchema in PyFlink ? Since I look at the documentation and seem it is not supported yet.

Best,
Quynh

Sent from Mail for Windows

 

From: Dian Fu
Sent: Friday, April 22, 2022 9:36 PM
To: lan tran
Cc: user@flink.apache.org
Subject: Re: AvroRowDeserializationSchema

 

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 for Windows

 

From: lan tran
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 for Windows

 

 

 

Reply via email to