在flink作业中，我想在构造状态24小时后删除它。我查看了这篇文章并设置了状态生存时间（ttl），但是正如本文中提到的，状态删除是惰性/被动的，这可能会导致内存泄漏。
例如，在23小时57分钟之后，我收到了key的最后一条消息（'usa'，'male'，2018），之后就再也没有这个key的消息了。然后我将无法调用该键的函数和状态的ttl（'usa'，'male'，2018），然后它将永远保存在内存中。
本文提到使用计时器： The idea is to register a timer with the TTL per state value and access. When the timer elapses, the state can be cleared if no other state access happened since the timer was registered. 但我不知道怎么做。
我在考虑使用 ProcessFunction 它有一个 onTimer() 方法。我的计划是注册一个 ProcessingTimeTimer 在它的 open() 方法，并删除中的状态 onTimer() ，但我不知道这个计时器是否也是被动触发的，这意味着如果没有调用 ProcessFunction 即使24小时后。