I’m wondering that why you use a beta feature for production. Why not push the latest state into down sink like redis or hbase with Apache phoenix .
________________________________ From: Annemarie Burger <[email protected]> Sent: Monday, May 18, 2020 11:19:23 PM To: [email protected] <[email protected]> Subject: Re: Incremental state with purging Hi, Thanks for your suggestions! However, as I'm reading the docs for queryable state, it says that it can only be used for Processing time, and my windows are defined using event time. So, I guess this means I should use the KeyedProcessFunction. Could you maybe suggest a rough implementation for this? I can't seem to get the implementation working right. Best, Annemarie -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
