Arbitrary stateful aggregation: updating state without setting timeout

[יורי אולייניקוב <yur...@gmail.com>]

Hi all, I have following question:

What happens to the state (in terms of expiration) if I’m updating the
state without setting timeout?


E.g. in FlatMapGroupsWithStateFunction

   1. first batch:

state.update(myObj)

state.setTimeoutDuration(timeout)

   1. second batch:

state.update(myObj)

   1. third batch (no data for a long time):
      1. ???? state timed-out after initial timeout  expired? Not
      timed-out?