Re: Shared state between two process functions

2020-06-17 Thread Congxian Qiu
t;> 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 >> *Send Da

Re: Shared state between two process functions

2020-06-15 Thread Robert Metzger
gt; *To:* Jaswin Shah ; 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

Re: Shared state between two process functions

2020-06-15 Thread Jaswin Shah
thinking of some shared state accessible between multiple keyedprocessfunctions. Get Outlook for Android<https://aka.ms/ghei36> From: Yun Gao Sent: Monday, June 15, 2020 8:27:38 AM To: Jaswin Shah ; user@flink.apache.org Subject: Re: Shared state between two p

Re: Shared state between two process functions

2020-06-14 Thread Yun Gao
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 S

Shared state between two process functions

2020-06-14 Thread Jaswin Shah
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