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 <annemarie.bur...@campus.tu-berlin.de> Sent: Monday, May 18, 2020 11:19:23 PM To: user@flink.apache.org <user@flink.apache.org> 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/
