flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tzu-Li (Gordon) Tai" <tzuli...@apache.org>
Subject Re: Cannot used managed keyed state in sink
Date Mon, 26 Feb 2018 07:39:39 GMT
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 (duckientruong@gmail.com) 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
Mime
View raw message