Cannot used managed keyed state in sink

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Cannot used managed keyed state in sink

Kien Truong
Hi,

It seems that I can't used managed keyed state inside sink functions. Is this unsupported with Flink 1.4 or am I doing something wrong ?

Regards,
Kien

Sent from TypeApp
Reply | Threaded
Open this post in threaded view
|

Re: Cannot used managed keyed state in sink

Tzu-Li (Gordon) Tai
Hi,

Are you using a `RichSinkFunction`? There you should have access to the runtime context, with which you can use to access keyed state.

Cheers,
Gordon

On 24 February 2018 at 3:04:55 PM, Kien Truong ([hidden email]) wrote:

Hi,

It seems that I can't used managed keyed state inside sink functions. Is this unsupported with Flink 1.4 or am I doing something wrong ?

Regards,
Kien

Sent from TypeApp