开发者社区> 问答> 正文

请教一下flink1.12可以指定时间清除state吗?

Hi,社区的各位大家好: 请教一下,我目前生产上使用的flink1.12,根据公司需求,统计每天的日报,每天出一组结果。已经做了group by current_date,userId  过程中我发现隔天的flink state未清理,还是在前一天的结果上累加,自己也测试了 1、Stream的TTL  2、tabEnv.getConfig().setIdleStateRetention(Duration.ofDays(1))这两种方式并不能满足我的需求,请教一下有其他方法可以实现这种日报需求吗?*来自志愿者整理的flink邮件归档

展开
收起
又出bug了-- 2021-12-02 11:51:42 673 0
1 条回答
写回答
取消 提交回答
  • 你这个直接按照天分窗就可以呀。*来自志愿者整理的FLINK邮件归档

    2021-12-02 14:36:07
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
Apache Flink 流式应用中状态的数据结构定义升级 立即下载
Flink State & Fault Tolerance 立即下载
Flink Forward China ——基于Apache Flink的搜索处理平台 立即下载