java - 弗林克 : possible to delete Queryable state after X time?

Question

就我而言，我仅使用 Flink 的可查询状态。特别是，我不关心检查点。

发生事件时，我仅在最多 X 分钟后查询可查询状态。理想情况下，我会删除“旧”状态以节省空间。

这就是为什么我想知道:我可以发出信号让 Flink 的状态在一段时间后自行清除吗？通过配置？通过特定的事件信号？怎么办？

Answer 1

清除状态的一种方法是，当特定键不再需要状态对象(例如 ValueState 对象)时，显式调用它的 clear() 。这通常是在 ProcessFunction 中的 onTimer() 回调中完成的。

另一种可能的方法是使用 state time-to-live管理其生命周期。

我还没有尝试过将状态 TTL 与可查询状态一起使用，但我看不出它不起作用的任何原因。但是，从 Flink 1.7 开始，状态 TTL 仅在访问(针对该键)状态或拍摄完整状态快照时才实际清除(针对该键)状态。因此，在您的特定情况下，这种状态 TTL 机制可能不是很有用。