Flink ValueState<JSONObject> checkpoint失败，导致状态重置
已解决
问题
想用flink 的valueState 加上ttl的特性来做中间状态的存储，但是发现假如直接用ValueState来保存中间状态是没问题的，但是假如加上TTL的特性之后checkpoint就失败了，导致无法使用。
代码示例
报错信息
debug
这个会不为2，导致checkpoint 失败，task重启，open方法重新执行，状态重置。
疑问
- 要用TTL这个特性是否一定要用rocksDB作为checkpoint的存储介质？我看官网的文档并没有这个说明；
- 还是fastJson 的JSONObject无法序列化导致的，但是为什么不加TTL是可以使用的？
- 应该怎么才能用ValueState 加上TTL这个淘汰机制呢（实现比如最近3天这个key没有更新，状态重置，重新从0开始计算，目前我是用了redis来做的，想直接用flink的状态来替换）？
展开
收起
1
条回答
写回答
写回答
-
个人博客: http://wuchong.me采纳回答我觉得这个应该是个 bug，可以在Flink 邮件列表中提问下。
可以不用 TTL 机制，可以通过 ProcessFunction 注册 3天的 Timer 来绕过，Timer 回调时删除对应 key 的状态。
社区同学提醒，一护：这个问题最新版应该已经解了，是因为ttl state的序列化器在duplicate的时候少传了一个参数
issue 链接：https://issues.apache.org/jira/browse/FLINK-10567
1.6.3 版本已经修复了这个问题。2019-07-17 23:18:18赞同 2 展开评论 打赏
问答分类：
问答标签：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
