Re: Flink Session Windows State TTL

Sorry, I pressed the send button too fast. You also attached an exception to the email, which reads as follows: Caused by: org.apache.flink.runtime.resourcemanager.exceptions.UnfulfillableSlotRequestException: Could not fulfill slot request c28970b7cd4f68383e242703bdac81ca. Requested resource pr

Re: Flink Session Windows State TTL

Hey Karl, sorry for the late reply! Let me first quickly answer your questions: > >- are expired session windows automatically removed from state? if >not, what's the best way to do it? > > Yes, they should get removed automatically. > >- >- how can we query state size? > > You

Re: Flink Session Windows State TTL

Added flink_oom_exception.txt as originally forgot to attach it -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Flink Session Windows State TTL

Hi all,We have an Apache Flink application which generates player sessions based on player events keyed by playerId. Sessions are based on EventTime. A session is created on first event event for that player and closes if there are 30 mins of inactivity. Events are merged in our custom /PlayerSessi