Re: Flink Statefun TTL

2021-02-24 Thread Tzu-Li (Gordon) Tai
On Thu, Feb 25, 2021 at 12:06 PM Timothy Bess wrote: > Hi Gordon, > > Ah so when it said "all registered state" that means all state keys > defined in the "module.yaml", not all state for all function instances. So > the expiration has always been _per_ instance then and not across all > instance

Re: Flink Statefun TTL

2021-02-24 Thread Timothy Bess
Hi Gordon, Ah so when it said "all registered state" that means all state keys defined in the "module.yaml", not all state for all function instances. So the expiration has always been _per_ instance then and not across all instances of a function. Thanks for the heads up, that sounds like a good

Re: Flink Statefun TTL

2021-02-24 Thread Tzu-Li (Gordon) Tai
Hi Timothy, Starting from StateFun 2.2.x, in the module.yaml file, you can set for each individual state of a function an "expireMode" field, which values can be either "after-invoke" or "after-write". For example: ``` - function: meta: ... spec: states: - name: state-

Flink Statefun TTL

2021-02-24 Thread Timothy Bess
Hey, I noticed that the Flink Statefun 2.1.0 release notes had this snippet with regards to TTL: Note: The state expiration mode for remote functions is currently > restricted to AFTER_READ_AND_WRITE, and the actual TTL being set is the > longest duration across all registered state, not for each