You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Ori Popowski <or...@gmail.com> on 2020/06/23 14:11:34 UTC
State leak
Hi,
When working with an ever growing key-space (let's say session ID), and a
SessionWindow with a ProcessFunction - should we worry about the state
growing indefinitely? Or does the window make sure to clean state after
triggers?
Thanks
Re: State leak
Posted by Ori Popowski <or...@gmail.com>.
Hi, thanks for answering.
Sounds reasonable
On Wed, Jun 24, 2020 at 11:50 AM Rafi Aroch <ra...@gmail.com> wrote:
> Hi Ori,
>
> Once a session ends, it's state should get purged. You should take care
> that a session does end.
> For example, if you wait for a 'session-end' event, limit it with some
> time threshold. If it's defined with inactivity gap and your client sends
> infinite events, you could limit the session length to enforce a new
> session (may be simpler done on the client side).
>
> Hope this helps,
> Rafi
>
>
> On Tue, Jun 23, 2020 at 5:11 PM Ori Popowski <or...@gmail.com> wrote:
>
>> Hi,
>>
>> When working with an ever growing key-space (let's say session ID), and a
>> SessionWindow with a ProcessFunction - should we worry about the state
>> growing indefinitely? Or does the window make sure to clean state after
>> triggers?
>>
>> Thanks
>>
>
Re: State leak
Posted by Rafi Aroch <ra...@gmail.com>.
Hi Ori,
Once a session ends, it's state should get purged. You should take care
that a session does end.
For example, if you wait for a 'session-end' event, limit it with some time
threshold. If it's defined with inactivity gap and your client sends
infinite events, you could limit the session length to enforce a new
session (may be simpler done on the client side).
Hope this helps,
Rafi
On Tue, Jun 23, 2020 at 5:11 PM Ori Popowski <or...@gmail.com> wrote:
> Hi,
>
> When working with an ever growing key-space (let's say session ID), and a
> SessionWindow with a ProcessFunction - should we worry about the state
> growing indefinitely? Or does the window make sure to clean state after
> triggers?
>
> Thanks
>