请问如何清除 flink 的状态？

你处理完了手动清除下状态不就完了

看看是不是 ttl 的时间设置的太短，数据还没 join 上就把 state 清了呗

@liprais 怎么手动清理啊，大佬给个关键字

@QunLeLZ 问题在于我无法给出一个合适的 ttl ，收到的报警的状态是会改变的，比如昨天报警出现了，没人知道它什么时候能恢复，不管我怎么设置 ttl 都有可能使得 es 中的状态不对

@xianzhe 你怎么设置状态就怎么清理呗
我很好奇你是怎么把 state 和 es 关联起来的
state ttl 应该只影响 flink 自己的 state,要清除 es 里面的不是得写 code 去改么...

flink state 设置 ttl 是可以清理状态的，需要注意 ttl 的清理策略，是写时和创建更新还是读时和写时更新；

@liprais 比如 join 进来信息是用 inner join 的，join 进来的表里 ttl 过期了，那 join 的结果就是空的，然后 es 里的数据就没了。大佬你看我上面的回复，我感觉核心问题在于我没法给一个确定的 ttl 。

@xianzhe #7 修改状态后端吧，把 state 写到本地文件系统，就不会内存一直涨，能避免 flink 任务持续运行可能导致的状态数量暴增而内存不足的情况，但是最好还是给一个 ttl ，不然本地文件系统的 state 还是会一直涨，不过可以把 ttl 设置长些。因为 flink 的 join 是比较麻烦的事情，尤其是这种后面数据会更新的情况。当然，写 java 代码的话，可以识别是更新数据，就让 flink 抛弃，你自己写代码去更新 es 的某个字段。。这是我的想法，有问题轻喷。。