关闭FeatureFlag后，如何强制清理指定StateDescriptor的Flink Keyed State？

背景 #

• 正在开发一个基于Flink Keyed State的Sink算子，状态后端采用堆内存模式，State TTL设置为24小时
• 业务逻辑：先捕获请求并将相关数据存入ValueState，待捕获到响应后，结合请求与响应完成后续逻辑处理
• 为应对生产环境中状态增长可能远超预期的问题，新增了featureFlag配置项：当flag为true时算子正常执行；为false时直接跳过核心逻辑（遵循Flink不推荐在Checkpoint之间增删有状态算子的最佳实践）

当前问题 #

关闭featureFlag后，无法快速清理已创建的Keyed State：

• 由于Keyed State的特性，缺少Key上下文时无法直接调用state.clear()
• 曾尝试在flag为false时将TTL改为1分钟，但查看Flink源码发现，若StateBackend中已存在对应StateDescriptor的状态，会直接复用原有状态，新的TTL配置不会生效

核心困境 #

1. 无法修改已存在状态的TTL配置
2. 后续可能无法再接收到相同Key的消息，无法获取清理状态所需的Key上下文

疑问 #

是否存在基于StateDescriptor强制清理状态的方法？还是只能等待24小时的TTL自动过期？

补充说明 #

该问题关联类似的状态清理场景，但无法采用常规解决方案：

• 不适用Keyed State的回调清理机制：ValueState仅关联当前处理的Key，回调无法覆盖所有已存在的状态
• 资源限制：若存储数百万个清理回调，会引发内存与Checkpoint大小的问题，反而不如等待TTL过期

内容的提问来源于stack exchange，提问作者midikko