Reading Flink states from svaepoint uning State Processor API

[min.tan]

Hi,

 

I am using Flink 1.10.1 and try to read the flink states from a savepoint using Flink state processor API.

It works well when state types are the normal Java type or Java POJOs.

 

When Avro generated Java classes are used as the state type, it does not read any states anymore.

 

Are any additional customer serializers required in this situation?

 

Regards,

Min

 

 

E-mails can involve SUBSTANTIAL RISKS, e.g. lack of confidentiality, potential manipulation of contents and/or sender's address, incorrect recipient (misdirection), viruses etc. Based on previous e-mail correspondence with you and/or an agreement reached with you, UBS considers itself authorized to contact you via e-mail. UBS assumes no responsibility for any loss or damage resulting from the use of e-mails.
The recipient is aware of and accepts the inherent risks of using e-mails, in particular the risk that the banking relationship and confidential information relating thereto are disclosed to third parties.
UBS reserves the right to retain and monitor all messages. Messages are protected and accessed only in legally justified cases.
For information on how UBS uses and discloses personal data, how long we retain it, how we keep it secure and your data protection rights, please see our Privacy Notice http://www.ubs.com/privacy-statement

[Till Rohrmann]

Hi Min,

Usually, you should be able to provide type information and thereby a serializer via the StateDescriptors which you create to access the state. If this is not working, then you need to give us a bit more context to understand what's not working.

I am also pulling in Seth who is the original author of the state processor API.

Cheers,

Till

On Mon, May 31, 2021 at 4:00 PM Tan, Min <[hidden email]> wrote:

Hi,

 

I am using Flink 1.10.1 and try to read the flink states from a savepoint using Flink state processor API.

It works well when state types are the normal Java type or Java POJOs.

 

When Avro generated Java classes are used as the state type, it does not read any states anymore.

 

Are any additional customer serializers required in this situation?

 

Regards,

Min

 

 

[Seth Wiesman]

Hi Min,

The only requirement is that your state descriptors be configured identically as those used in your datastream API. So if you registered custom TypeInformation / serializer in your streaming job you will need those here as well. I would also look at the ExecutionConfig on your DataStream app as that can dictate how your serializers are configured.

Seth

On Tue, Jun 1, 2021 at 10:24 AM Till Rohrmann <[hidden email]> wrote:

Hi Min,

Usually, you should be able to provide type information and thereby a serializer via the StateDescriptors which you create to access the state. If this is not working, then you need to give us a bit more context to understand what's not working.

I am also pulling in Seth who is the original author of the state processor API.

Cheers,

Till

On Mon, May 31, 2021 at 4:00 PM Tan, Min <[hidden email]> wrote:

Hi,

 

I am using Flink 1.10.1 and try to read the flink states from a savepoint using Flink state processor API.

It works well when state types are the normal Java type or Java POJOs.

 

When Avro generated Java classes are used as the state type, it does not read any states anymore.

 

Are any additional customer serializers required in this situation?

 

Regards,

Min