Re: The trigger of State TTL

2020-06-02 Thread Andrey Zagrebin
Hi Lec Ssmi, It depends on the state backend you use. The heap state backend needs that either some state access happens or some records get processed in the operator [1]. The RocksDB requires that the state size is big enough (roughly speaking) to trigger the compaction process to clean the expir

The trigger of State TTL

2020-06-02 Thread lec ssmi
As we known, flink can set certain TTL config for the state, so that the state can be automatically cleared after being idle for a period of time. But if there is no new record coming in after setting the TTL config , will the state be automatically cleared after a certain time? Or does it re