Basically, I have multiple processafunctions and they are doing some.computations based on some historical results and the historical events and results are common across the process functions due to which I have a lot of redundant processing in many process functions so, I have been thinking of some shared state accessible between multiple keyedprocessfunctions.
Get Outlook for Android<https://aka.ms/ghei36> ________________________________ From: Yun Gao <yungao...@aliyun.com> Sent: Monday, June 15, 2020 8:27:38 AM To: Jaswin Shah <jaswin.s...@outlook.com>; user@flink.apache.org <user@flink.apache.org> Subject: Re: Shared state between two process functions Hi Jaswin, Currently the state belongs to single operators, thus it should be not possible to share states between different operators. Could you also share the original problem want to solve by sharing states ? Best, Yun ------------------Original Mail ------------------ Sender:Jaswin Shah <jaswin.s...@outlook.com> Send Date:Sun Jun 14 18:57:54 2020 Recipients:user@flink.apache.org <user@flink.apache.org> Subject:Shared state between two process functions Hi, Is it possible to create the shared state(MapState) between two different keyedProcessFunction? If it's possible, how can we do that in flink? Thanks, Jaswin
